File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change 66@heartbeat_sent .connect
77def heartbeat (sender , ** kwargs ):
88 worker_name = sender .eventer .hostname .split ('@' )[0 ]
9- heartbeat_path = Path ('/tmp/worker_heartbeat_{}' .format (worker_name ))
9+ heartbeat_path = Path ('/opt/maxkb-app/ tmp/worker_heartbeat_{}' .format (worker_name ))
1010 heartbeat_path .touch ()
1111
1212
1313@worker_ready .connect
1414def worker_ready (sender , ** kwargs ):
1515 worker_name = sender .hostname .split ('@' )[0 ]
16- ready_path = Path ('/tmp/worker_ready_{}' .format (worker_name ))
16+ ready_path = Path ('/opt/maxkb-app/ tmp/worker_ready_{}' .format (worker_name ))
1717 ready_path .touch ()
1818
1919
2020@worker_shutdown .connect
2121def worker_shutdown (sender , ** kwargs ):
2222 worker_name = sender .hostname .split ('@' )[0 ]
2323 for signal in ['ready' , 'heartbeat' ]:
24- path = Path ('/tmp/worker_{}_{}' .format (signal , worker_name ))
24+ path = Path ('/opt/maxkb-app/ tmp/worker_{}_{}' .format (signal , worker_name ))
2525 path .unlink (missing_ok = True )
You can’t perform that action at this time.
0 commit comments