diff --git a/temporal/activity.py b/temporal/activity.py index 9e29497..6e29573 100644 --- a/temporal/activity.py +++ b/temporal/activity.py @@ -101,7 +101,7 @@ async def call_callback_ahm(params): LOCK_KEY = "lock:aeros_process" -LOCK_TIMEOUT = 180 # seconds +LOCK_TIMEOUT = 864000 # seconds @activity.defn async def acquire_lock(job_id: str) -> dict: diff --git a/temporal/workflow.py b/temporal/workflow.py index 7b33d39..bcfab7d 100644 --- a/temporal/workflow.py +++ b/temporal/workflow.py @@ -27,7 +27,7 @@ class SimulationWorkflow: await workflow.execute_activity( acquire_lock, sim_data["HubCnnId"], - start_to_close_timeout=timedelta(minutes=10), + start_to_close_timeout=timedelta(days=10) ) self.status = "RUNNING"