You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
from faktory import Worker
import logging
import time
def your_function(x, y):
time.sleep(15)
return x + y
w = Worker(queues=['default'], concurrency=1)
w.register('test', your_function)
print(w.get_worker_id())
logging.basicConfig(level=logging.DEBUG)
w.run() # runs until control-c or worker shutdown from Faktory web UI
worker id prints as 32860cb098ae4e13ab8a7f44af498bf1
but heartbeat shows
DEBUG:faktory.worker:Sending heartbeat for worker 9e9775cb1abc47b7b6c6bc1ec6689610
looking in the web interface it seem that the debug message contains the correct id.
The text was updated successfully, but these errors were encountered:
I run the folowing example
worker id prints as 32860cb098ae4e13ab8a7f44af498bf1
but heartbeat shows
DEBUG:faktory.worker:Sending heartbeat for worker 9e9775cb1abc47b7b6c6bc1ec6689610
looking in the web interface it seem that the debug message contains the correct id.
The text was updated successfully, but these errors were encountered: