Skip to content

Commit

Permalink
Remove limit of running 1 trigger at a time
Browse files Browse the repository at this point in the history
using max_instances=10_000 in aps as it doesn't support inf

#256
  • Loading branch information
lucafaggianelli committed Jul 29, 2024
1 parent dd2e751 commit b3ad55e
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion src/plombery/orchestrator/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -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):
Expand Down Expand Up @@ -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(),
),
Expand Down

0 comments on commit b3ad55e

Please sign in to comment.