hunk.code_window:             elif ti.is_runnable(flag_upstream_failed=True):
                   self.logger.debug('Queuing task: {}'.format(ti))
                   queue.put((ti.key, pickle_id))
               else:
  
hunk.labels: keep keep add keep
hunk.after_edit:             elif ti.is_premature():
                   continue
  
hunk.file_path: airflow/jobs.py
hunk.type: add