directed-acyclic-graphs

2熱

1答えて

同じ階層を描画する2つの異なる方法があります。「スタックされた」レイアウトでは、ノードは常に、最も高い「子」ノードよりも1つ上のレイヤーです。（重要：別例えば、質問の下部にある編集を参照してください）層状の描画メソッドこれらの2つのタイプの操作を行い、特定の名前を持っていますか？私は "積み重なった"ものの既存のアルゴリズムを見つけようとしていますが、何が呼び出されたのかわからないので、何ら

0熱

1答えて

エアフローは、1分後に自分のタスクを殺す

私が持っている次のような二つのタスクと非常にシンプルなDAG、：： default_args = { 'owner': 'me', 'start_date': dt.datetime.today(), 'retries': 0, 'retry_delay': dt.timedelta(minutes=1) } dag = DAG( 'test

0熱

1答えて

ダグ内の気流の上流のタスクをクリア

私は気流DAGの中にタスクを持っています。 3つの子タスクがあります。残念ながら、この親タスクが成功するケースがありますが、3人の子どものうちの2人が失敗します（子どもの再試行は失敗しません）。（失敗していなくても）再試行する必要があります。私はdagのグラフビューに行き、この親タスクとすべての下流タスク（+再帰的）を 'クリア'します。私はダッグ自体の中でこれを行うことができますか？

2熱

1答えて

TriggerDagRunOperatorを使用して別のDAGを複数回実行する

DAG（DAG1）を使用しています。私は、コピーされた各ファイルの別のDAG（DAG2）を開始したいと思います。 DAG1の実行ごとにコピーされるファイルの数が異なるため、本質的にファイルをループしてDAG2を適切なパラメータで呼び出したいと思います。例： with DAG('DAG1', description="copy files over", schedule_i

0熱

1答えて

TEZに生成されたDAG計画にカスタムDAG計画を適用できますか？可能であれば、どのように？

HiveでTEZによって生成されたDAG計画を使用する代わりに、私が作成したカスタムDAG計画を使用したいと思います。出来ますか？はい、誰でも説明できますか？

1熱

2答えて

気流DAGが一度に1日に実行されるようにするにはどうすればよいですか？

DAGを一度に1日実行するように設定したいとします。これをどうすれば実現できますか？私は "depends on past = True"を試しましたが、各タスクが後で実行されることを確認します。私が欲しいのは、もし私がX日から戻ってきたなら、X日のすべてのタスクがX + 1日のDAGの前に実行されるということです。

0熱

1答えて

エアフローを再起動スケジューラなしでロードすることができます。

私の場合、ダグパスの下にダグファイルを書きます。エアフロースケジューラを起動すると、ダグファイルが正常に読み込まれます。ただし、dagファイルを変更した後、dagファイルをロードすることが致命的でした。再起動スケジューラを使わずにダグファイルを作成する方法はありますか？

2熱

1答えて

はどのようにして、リンク、次のIを発見したTriggerDagRunOperator

を使用して-dagエアフローをトリガします。このドキュメントでは、Airflow独自のサンプルダグを使用していますが、センサを使用していないため、それらを理解するのは難しいです。誰かがTriggerDagRunOperatorとSqlSensorを使用して個別のダグを開始する方法を説明できますか？私はSQL Serverの仕事の仕事が終わったときに別々のDAGを開始しようとしています。私はSql

2熱

2答えて

graphvizでこのグラフを非周期的にするにはどうすればいいですか？

初回DOT/GraphVizユーザーはここにいます。私はそれがこの私はどのように表現するかのようにレンダリングされたいのですが、一方、こののようにレンダリングされる次のグラフ digraph G { rankdir=LR; "START" -> "A" -> "B" -> "A" -> "C" -> "A" -> "END" "START" -> "A" -> "