SIENTIAPDE-1141
SIENTIAPDE-1141 Update worker.py to configure concurrency limits for workflow tasks and activities, enhancing performance and resource management.
This commit is contained in:
@@ -76,7 +76,12 @@ async def main():
|
|||||||
activities.load_custom_query,
|
activities.load_custom_query,
|
||||||
activities.repeat_last_prediction,
|
activities.repeat_last_prediction,
|
||||||
activities.export_data_to_postgres
|
activities.export_data_to_postgres
|
||||||
]
|
],
|
||||||
|
max_concurrent_workflow_tasks=100,
|
||||||
|
max_concurrent_activities=100,
|
||||||
|
max_concurrent_local_activities=100,
|
||||||
|
max_concurrent_workflow_task_polls=100,
|
||||||
|
max_cached_workflows=50,
|
||||||
)
|
)
|
||||||
]
|
]
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user