Hi,
Please help me to fix this error. The job seems running in the dataflow
console. But getting following assertion error.
/local/lib/python2.7/site-packages/apache_beam/io/gcp/gcsio.py:166:
DeprecationWarning: object() takes no parameters
super(GcsIO, cls).__new__(cls, storage_client))
Traceback (most recent call last):
File "/usr/lib/python2.7/runpy.py", line 174, in _run_module_as_main
"__main__", fname, loader, pkg_name)
File "/usr/lib/python2.7/runpy.py", line 72, in _run_code
exec code in run_globals
File "/home/gw/src/legacy/dataflow/cma/report/build.py", line 96, in <module>
run()
File "/home/gw/src/legacy/dataflow/cma/report/build.py", line 91, in run
return p.run().wait_until_finish()
File
"/home/gw/venvs/dfvenv-0.2.0/local/lib/python2.7/site-packages/apache_beam/runners/dataflow/dataflow_runner.py",
line 989, in wait_until_finish
'Job did not reach to a terminal state after waiting indefinitely.')
AssertionError: Job did not reach to a terminal state after waiting
indefinitely.
Regards,
Prabeesh K.
