どのタスクにいるのかわからないまま、実行中のタスク内でタスク ID を取得したい (そのため、https://stackoverflow.com/a/8096086/245024を使用できません) 。
私はそれが次のようなものであることを望みます:
@task
def my_task():
foo()
def foo():
logger.log(current_task_id)
このパターンはさまざまなタスクで返されるため、すべての内部メソッド呼び出しにタスク コンテキストを適用したくありません。
1 つのオプションとして、スレッド ローカル ストレージを使用することもできますが、その場合、タスクの開始前に初期化し、終了後にクリーンアップする必要があります。
もっと簡単なものはありますか？