This is an automated email from the ASF dual-hosted git repository. jhtimmins pushed a commit to branch v2-1-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit dd3c06f21a71d8b4a3e485895ca26c543adc9523 Author: vikram Jadhav <[email protected]> AuthorDate: Thu Jun 24 22:57:20 2021 +0530 commiting dagPickle session when the airflow tasks run --ship-dag --interactive command is executed FIXES: 15748 (#15890) (cherry picked from commit 86d0a96bf796fd767cf50a7224be060efa402d94) --- airflow/cli/commands/task_command.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/airflow/cli/commands/task_command.py b/airflow/cli/commands/task_command.py index 0302d4d..6dd36db 100644 --- a/airflow/cli/commands/task_command.py +++ b/airflow/cli/commands/task_command.py @@ -80,9 +80,9 @@ def _run_task_by_executor(args, dag, ti): with create_session() as session: pickle = DagPickle(dag) session.add(pickle) - pickle_id = pickle.id - # TODO: This should be written to a log - print(f'Pickled dag {dag} as pickle_id: {pickle_id}') + pickle_id = pickle.id + # TODO: This should be written to a log + print(f'Pickled dag {dag} as pickle_id: {pickle_id}') except Exception as e: print('Could not pickle the DAG') print(e)
