diff --git a/mula/scheduler/schedulers/schedulers/report.py b/mula/scheduler/schedulers/schedulers/report.py index 05374ea9d0f..52578c13af4 100644 --- a/mula/scheduler/schedulers/schedulers/report.py +++ b/mula/scheduler/schedulers/schedulers/report.py @@ -98,7 +98,7 @@ def push_tasks_for_rescheduling(self): filters=filters.FilterRequest( filters=[ filters.Filter(column="hash", operator="eq", value=report_task.hash), - filters.Filter(column="schedule_id", operator="eq", value=schedule.id), + filters.Filter(column="schedule_id", operator="eq", value=str(schedule.id)), ] ), )