def get_task_runner(local_task_job):
 if (_TASK_RUNNER == 'BashTaskRunner'):
  return BashTaskRunner(local_task_job)
 elif (_TASK_RUNNER == 'CgroupTaskRunner'):
  from airflow.contrib.task_runner.cgroup_task_runner import CgroupTaskRunner
  return CgroupTaskRunner(local_task_job)
 else:
  raise AirflowException('Unknown task runner type {}'.format(_TASK_RUNNER))

def get_task_runner ( local_task_job ) : if ( _TASK_RUNNER == 'BashTaskRunner' ) : return BashTaskRunner ( local_task_job ) elif ( _TASK_RUNNER == 'CgroupTaskRunner' ) : from airflow . contrib . task_runner . cgroup_task_runner import CgroupTaskRunner return CgroupTaskRunner ( local_task_job ) else : raise AirflowException ( 'Unknown task runner type {}' . format ( _TASK_RUNNER ) )
get the task runner that can be used to run the given job .