diff options
Diffstat (limited to 'zuul/driver/timer/__init__.py')
| -rw-r--r-- | zuul/driver/timer/__init__.py | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/zuul/driver/timer/__init__.py b/zuul/driver/timer/__init__.py index 37fdcf580..dcc013788 100644 --- a/zuul/driver/timer/__init__.py +++ b/zuul/driver/timer/__init__.py @@ -226,6 +226,7 @@ class TimerDriver(Driver, TriggerInterface): event.branch = branch event.zuul_event_id = str(uuid4().hex) event.timestamp = time.time() + event.arrived_at_scheduler_timestamp = event.timestamp # Refresh the branch in order to update the item in the # change cache. change_key = project.source.getChangeKey(event) @@ -234,7 +235,9 @@ class TimerDriver(Driver, TriggerInterface): event=event) log = get_annotated_logger(self.log, event) log.debug("Adding event") - self.sched.addTriggerEvent(self.name, event) + self.sched.pipeline_trigger_events[tenant.name][ + pipeline_name + ].put(self.name, event) except Exception: self.log.exception("Error dispatching timer event for " "tenant %s project %s branch %s", |