We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9d9897e commit 2816cf6Copy full SHA for 2816cf6
run_ac.py
@@ -180,16 +180,15 @@ def make_batches(
180
async def process_async_llm_calls_a2vybg(
181
record_dict_list: List[Dict[str, Any]]
182
) -> None:
183
-
184
batch_size = max(amount_a2vybg // int(attribute_calculators.NUM_WORKERS_A2VYBG), 1)
185
tasks = [
186
process_llm_record_batch_a2vybg(batch)
187
for batch in make_batches(record_dict_list, size=batch_size)
188
]
189
await asyncio.gather(*tasks)
+ send_cache_to_object_storage_a2vybg()
190
if check_abort_status_a2vybg():
191
raise ValueError("Encountered error during LLM processing.")
192
- send_cache_to_object_storage_a2vybg()
193
194
195
if __name__ == "__main__":
0 commit comments