問題タブ [celery-task]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票する
1 に答える
4309 参照

python - タスクの 1 つが失敗するとセロリ チェーンが壊れる

タスクの 1 つが失敗した場合、チェーン全体が壊れる場合、Celery チェーンのポイントは何ですか?!!

私はこのセロリチェーンを持っています:

そして、次のような再試行で workme2 が失敗するようにしました。

0 投票する
2 に答える
1756 参照

celery - Celery サブタスクが最終結果を取得

を使用したメソッドでCeleryあるドキュメントの例を使用しようとすると、最終結果が得られません。addsubtask

でタスクを呼び出すと;

3ご覧のとおり、代わりに を返します8

これらの部分を実行すると、ワーカーにエラーが発生します。なぜそれが起こっているのかわかりません。

結果から8を取得するにはどうすればよいですか?

ありがとう!

0 投票する
1 に答える
3236 参照

celery - セロリマルチが期待どおりに機能しない

これは私のプロジェクトフォルダー構造です

タスクには、というタスクがありますExamineColumns

を使用してワーカーを起動しますcelery worker -A api.jobs --loglevel=Info

正常に動作し、タスクを実行できます。

これは、セロリの検査コマンドの出力です

しかし、マルチモードを試してみると、うまくいきません。実行して実行しようとしています

でも全然始まらない。

なぜ機能しないのかわかりません

0 投票する
3 に答える
5306 参照

python - セロリでは、特定のタスク名のすべてのタスクのタスクステータスを取得する方法は?

セロリでは、特定のタスク名のすべてのタスクのタスク ステータスを取得したいと考えています。そのために、以下のコードを試しました。

今、このコードで空のリストを取得しています。

0 投票する
0 に答える
266 参照

celery - Celery タスク チェーン/ワーカー リリース

他のセロリ タスクを呼び出すセロリ タスクを作成した場合、下流のタスクが完了するのを待たずに親タスク/ワーカーを解放できますか?

状況: 次の API 呼び出しのデータと引数を返す API を使用しています。API の背後にあるすべてのデータをデータベースに入れたい。私の現在の方法は、バッチが動作するように API をクエリし、いくつかのダウンストリーム プロセッサを起動してから、API+処理チェーンを再帰的に再呼び出しすることです。これにより、ワーカーが子の結果を気にしない場合、すべての再帰 API 呼び出しが完了するのを待っているワーカーがロックされるのではないかと心配しています。

擬似コード:

ここから、上記は非常に悪いことに近いことを理解しています。API 内のすべてのデータが処理されるまで、processList() を処理するワーカーをロックしたくありません。ダウンストリーム タスクを開始して親ワーカーを解放する方法、またはワーカーをロックしないように上記をリファクタリングする方法はありますか?

テストの結果、ワーカーは実際には次のようにロックされていることがわかりました。

0 投票する
2 に答える
58548 参照

python - セロリ ワーカー エラー: ImportError セロリという名前のモジュールがありません

セロリ ワーカーを起動しようとすると、インポート エラーが発生します。問題が何であるかわかりません。どんな助けでも大歓迎です。

私のプロジェクト:

私は呼び出してアプリケーションを実行しようとします:

ここのすべての手順に従いました - http://docs.celeryproject.org/en/latest/getting-started/next-steps.html#about-the-app-argument

トレースバック:

ここに私のcelery.pyがあります

0 投票する
4 に答える
18549 参照

python - セロリのインポートエラー

これは私が実行しているコードです:

上記のコードを実行すると、次のエラーが表示されます。