chore: define maximum parallel executions

camunda · Oct 7, 2024 · 82d5a4a · 82d5a4a
1 parent f653c52
commit 82d5a4a
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/scripts/tasks.py b/scripts/tasks.py
@@ -15,11 +15,14 @@ def add_task_to_router(router, secrets_manager, task_name, task_function):
     print("creating task " + "camunda::RPA-Task::" + task_name)
 
     timeout_seconds = int(os.environ.get("TIMEOUT_SECONDS", 60))
+    parallel_executions = int(os.environ.get("MAX_PARALLEL_EXECUTIONS", 1))
 
     @router.task(
         task_type="camunda::RPA-Task::" + task_name,
         exception_handler=my_exception_handler,
         timeout_ms=timeout_seconds * 1000,
+        max_running_jobs=parallel_executions,
+        max_jobs_to_activate=parallel_executions,
     )
     async def rpa_task(job: Job):
         variables = job.variables.get("camundaRpaTaskInput") or job.variables