diff --git a/linspector/core/job.py b/linspector/core/job.py index 9317c59..49310ec 100644 --- a/linspector/core/job.py +++ b/linspector/core/job.py @@ -98,7 +98,7 @@ class Job: def handle_tasks(self, msg): for member in self.members: for task in member.get_tasks(): - if self.status.lower() == task.get_task_type(): + if self.status.lower() == task.get_task_type().lower(): logger.debug("Executing Task of type: " + self.status) TaskExecutor.Instance().schedule_task(msg, task)