0

找不到造纸厂操作员的输出文件/文件夹。阿帕奇气流 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 }}!"},
)
4

0 回答 0