diff --git a/worker.py b/worker.py index b2e2eb4..d756fd7 100644 --- a/worker.py +++ b/worker.py @@ -20,6 +20,7 @@ def worker_exception_handler(job, exc_type, exc_value, traceback): worker = Worker( queues=["default"], connection=r, exception_handlers=worker_exception_handler ) + logging.info("Registered the worker!") try: worker.work(with_scheduler=True, max_jobs=1) except KeyboardInterrupt: