[GitHub] [airflow] ihorton1 edited a comment on issue #13805: Could not get scheduler_job_id

[GitBox <gi...@apache.org>]

ihorton1 edited a comment on issue #13805:
URL: https://github.com/apache/airflow/issues/13805#issuecomment-844291902


   @dimberman unless I'm mistaken, it appears that although @MaxTaggart fixed the backfill issue related to this issue, the run command is still throwing the original error in 2.0.2.
   
   Would adding `job_id = 'manual'` in airflow/cli/commands/task_command.py fix the issue you think?
   
   ```
   def _run_task_by_executor(args, dag, ti):
       """
       Sends the task to the executor for execution. This can result in the task being started by another host
       if the executor implementation does
       """
       pickle_id = None
       if args.ship_dag:
           try:
               # Running remotely, so pickling the DAG
               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}')
           except Exception as e:
               print('Could not pickle the DAG')
               print(e)
               raise e
       executor = ExecutorLoader.get_default_executor()
       executor.job_id = 'manual'
       executor.start()
       print("Sending to executor.")
       executor.queue_task_instance(
           ti,
           mark_success=args.mark_success,
           pickle_id=pickle_id,
           ignore_all_deps=args.ignore_all_dependencies,
           ignore_depends_on_past=args.ignore_depends_on_past,
           ignore_task_deps=args.ignore_dependencies,
           ignore_ti_state=args.force,
           pool=args.pool,
       )
       executor.heartbeat()
       executor.end()
   ```
   
   If so, wondering how i should test it. Happy to take this on. 


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org