diff --git a/airflow/gcp/hooks/dataflow.py b/airflow/gcp/hooks/dataflow.py
index bd6e17e2d0..bd86d1587e 100644
--- a/airflow/gcp/hooks/dataflow.py
+++ b/airflow/gcp/hooks/dataflow.py
@@ -143,7 +143,6 @@ class _DataflowJobsController(LoggingMixin):
 
         for job in self._jobs:
             if job and 'currentState' in job:
-                self._job_state = job['currentState']
                 self.log.info(
                     'Google Cloud DataFlow job %s is %s',
                     job['name'], job['currentState']