title: How Airflow can create a dataflow job from a python operator?
body: <p>When I am running my Beam pipeline by the command line, using the direct runner or the dataflow runner, it works fine...</p>
  
  <p>Example:</p>
  
  <pre><code>$ python my_pipeline.py --key /path/to/gcp/service/key.json --project gcp_project_name
  </code></pre>
  
  <p>But when I am trying to use airflow, I have two options, bash operator or python operator.</p>
  
  <p>Using bash operator will success, but will limit my ability to use the airflow features.</p>
  
  <p>But what I am trying to do is to run it as a python operator. So I am importing the module inside the airflow dg file, and then run it as a python operator.</p>
  
  <p>It is also working fine if I am using the local runner, but when I changed it to the data flow runner, it fails after creating the job on GCP dataflow with this error</p>
  
  <p><code>ImportError: No module named airflow.bin.cli</code></p>
  
  <p>What I am missing to let <strong>Airflow</strong> create a <strong>dataflow</strong> job from a <strong>python</strong> operator?</p>