add lock timeout

main
Cizz22 2 weeks ago
parent 7fb967fa94
commit 6deb8749b0

@ -101,7 +101,7 @@ async def call_callback_ahm(params):
LOCK_KEY = "lock:aeros_process" LOCK_KEY = "lock:aeros_process"
LOCK_TIMEOUT = 180 # seconds LOCK_TIMEOUT = 864000 # seconds
@activity.defn @activity.defn
async def acquire_lock(job_id: str) -> dict: async def acquire_lock(job_id: str) -> dict:

@ -27,7 +27,7 @@ class SimulationWorkflow:
await workflow.execute_activity( await workflow.execute_activity(
acquire_lock, acquire_lock,
sim_data["HubCnnId"], sim_data["HubCnnId"],
start_to_close_timeout=timedelta(minutes=10), start_to_close_timeout=timedelta(days=10)
) )
self.status = "RUNNING" self.status = "RUNNING"

Loading…
Cancel
Save