title: How to trigger google dataproc job using airflow and pass parameter as well
body: <p>As a part of a DAG, I am triggering gcp pyspark dataproc job using below code,</p>
  <pre><code>   dag=dag,
     gcp_conn_id=gcp_conn_id,
     region=region,
     main=pyspark_script_location_gcs,
     task_id='pyspark_job_1_submit',
     cluster_name=cluster_name,
     job_name=&quot;job_1&quot;
  )
  </code></pre>
  <p>How can I pass a variable as parameter to pyspark job that can be accessible in script ?</p>