'Test DataFlowPythonOperator instance is properly initialized.'

def test_init(self):

    self.assertEqual(self.dataflow.task_id, TASK_ID)
    self.assertEqual(self.dataflow.py_file, PY_FILE)
    self.assertEqual(self.dataflow.py_options, PY_OPTIONS)
    self.assertEqual(self.dataflow.dataflow_default_options, DEFAULT_OPTIONS)
    self.assertEqual(self.dataflow.options, ADDITIONAL_OPTIONS)
