osdir.com


[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

AssertionError: Job did not reach to a terminal state after waiting indefinitely.


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.