私はデータの前処理ルーチンに特化したクラスと異なるメソッドを実行し、次のDAGを、持っている： from datetime import datetime
import os
import sys
from airflow.models import DAG
from airflow.operators.python_operator import PythonOperator
im
エアフロースクリプトを使用してdataflow jarを実行しようとしています。私はDataFlowJavaOperatorを使用しています。 PARAMジャーでは、私はこのジョブを実行しようとすると、私は {gcp_dataflow_hook.py:108} INFO - Start waiting for DataFlow process to complete.
[2017-09-12 1
エアフローが初めてで、最初のDAGが作成されました。ここに私のDAGコードがあります。私はDAGを開始し、その後は1日に1回実行します。 from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from datetime import datetime, timedelta
defau