From b3ad55efc6840f062bd585e69d04277f0f98afa8 Mon Sep 17 00:00:00 2001 From: Luca Faggianelli Date: Mon, 29 Jul 2024 15:15:35 +0200 Subject: [PATCH] Remove limit of running 1 trigger at a time using max_instances=10_000 in aps as it doesn't support inf #256 --- src/plombery/orchestrator/__init__.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/plombery/orchestrator/__init__.py b/src/plombery/orchestrator/__init__.py index f2d4f5be..0791ea76 100644 --- a/src/plombery/orchestrator/__init__.py +++ b/src/plombery/orchestrator/__init__.py @@ -51,6 +51,7 @@ def register_pipeline(self, pipeline: Pipeline): coalesce=True, # Jobs will be run even if they arrive 1 min late misfire_grace_time=timedelta(minutes=1).seconds, + max_instances=10_000, ) def get_pipeline(self, pipeline_id: str): @@ -108,7 +109,7 @@ async def run_pipeline_now( "params": params, "pipeline_run": pipeline_run, }, - max_instances=1, + max_instances=10_000, misfire_grace_time=None, trigger=DateTrigger(), ),