I.e. we have task do_something(something_id) and before place new task i'd like to check is there already running task with particular something_id.
I came up with the method, which involves redis pubsub channel with id like 'do_something{}'.format(something_id) and task supervisor thread, which replays to some hello message to this channel, if the task running. So before place new task I send hello message to this channel, wait for reply and if no - place the task. But all this stuff is complicated and works not so well. Are there any other methods?
Aucun commentaire:
Enregistrer un commentaire