diff --git a/src/masonite/drivers/queue/DatabaseDriver.py b/src/masonite/drivers/queue/DatabaseDriver.py index dba74141d..4b38d3fe2 100644 --- a/src/masonite/drivers/queue/DatabaseDriver.py +++ b/src/masonite/drivers/queue/DatabaseDriver.py @@ -89,7 +89,8 @@ def consume(self): getattr(obj, callback)(*args) except AttributeError: - obj(*args) + if callable(obj): + obj(*args) self.success( f"[{job['id']}][{pendulum.now(tz=self.options.get('tz', 'UTC')).to_datetime_string()}] Job Successfully Processed"