找不到造纸厂操作员的输出文件/文件夹。阿帕奇气流 2.0。假设在 tmp 文件夹中。Output_nb="/tmp/out-{{ execution_date }}.ipynb" 我无法在任何地方找到文件或文件夹。
with DAG(
dag_id='fahar_papermill_operator_2',
schedule_interval='0 0 * * *',
start_date=days_ago(2),
dagrun_timeout=timedelta(minutes=60),
) as dag_2:
run_this = PapermillOperator(
task_id="run_example_notebook",
input_nb=os.path.join(os.path.dirname(os.path.realpath(__file__)),
"count_20.ipynb"),
output_nb="/tmp/out-{{ execution_date }}.ipynb",
parameters={"msgs": "Ran from Airflow at {{ execution_date }}!"},
)