[GitHub] [beam] tvalentyn commented on pull request #17551: Better test assertion.

[GitBox]

tvalentyn commented on PR #17551:
URL: https://github.com/apache/beam/pull/17551#issuecomment-1125716305

   I think this broke postcommits cc: @TheNeuralBit 
   
   ```
   E         
apache_beam.runners.dataflow.dataflow_runner.DataflowRuntimeException: Dataflow 
pipeline failed. State: FAILED, Error:
   E         Traceback (most recent call last):
   E           File "apache_beam/runners/common.py", line 1404, in 
apache_beam.runners.common.DoFnRunner.process
   E           File "apache_beam/runners/common.py", line 624, in 
apache_beam.runners.common.SimpleInvoker.invoke_process
   E           File 
"/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python38/src/sdks/python/apache_beam/io/gcp/bigquery_json_it_test.py",
 line 103, in process
   E             self.assertEqual(country_expected, country_actual)
   E           File "/usr/local/lib/python3.8/unittest/case.py", line 911, in 
assertEqual
   E             assertion_func = self._getAssertEqualityFunc(first, second)
   E           File "/usr/local/lib/python3.8/unittest/case.py", line 892, in 
_getAssertEqualityFunc
   E             asserter = self._type_equality_funcs.get(type(first))
   E         AttributeError: 'CompareJson' object has no attribute 
'_type_equality_funcs'
   E         
   E         During handling of the above exception, another exception occurred:
   E         
   E         Traceback (most recent call last):
   E           File 
"/usr/local/lib/python3.8/site-packages/dataflow_worker/batchworker.py", line 
646, in do_work
   E             work_executor.execute()
   E           File 
"/usr/local/lib/python3.8/site-packages/dataflow_worker/executor.py", line 208, 
in execute
   E             op.start()
   E           File "dataflow_worker/native_operations.py", line 38, in 
dataflow_worker.native_operations.NativeReadOperation.start
   E           File "dataflow_worker/native_operations.py", line 39, in 
dataflow_worker.native_operations.NativeReadOperation.start
   E           File "dataflow_worker/native_operations.py", line 44, in 
dataflow_worker.native_operations.NativeReadOperation.start
   E           File "dataflow_worker/native_operations.py", line 54, in 
dataflow_worker.native_operations.NativeReadOperation.start
   E           File "apache_beam/runners/worker/operations.py", line 514, in 
apache_beam.runners.worker.operations.Operation.output
   E           File "apache_beam/runners/worker/operations.py", line 226, in 
apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
   E           File "apache_beam/runners/worker/operations.py", line 893, in 
apache_beam.runners.worker.operations.DoOperation.process
   E           File "apache_beam/runners/worker/operations.py", line 894, in 
apache_beam.runners.worker.operations.DoOperation.process
   E           File "apache_beam/runners/common.py", line 1406, in 
apache_beam.runners.common.DoFnRunner.process
   E           File "apache_beam/runners/common.py", line 1478, in 
apache_beam.runners.common.DoFnRunner._reraise_augmented
   E           File "apache_beam/runners/common.py", line 1404, in 
apache_beam.runners.common.DoFnRunner.process
   E           File "apache_beam/runners/common.py", line 623, in 
apache_beam.runners.common.SimpleInvoker.invoke_process
   E           File "apache_beam/runners/common.py", line 1585, in 
apache_beam.runners.common._OutputProcessor.process_outputs
   E           File "apache_beam/runners/worker/operations.py", line 226, in 
apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
   E           File "apache_beam/runners/worker/operations.py", line 893, in 
apache_beam.runners.worker.operations.DoOperation.process
   E           File "apache_beam/runners/worker/operations.py", line 894, in 
apache_beam.runners.worker.operations.DoOperation.process
   E           File "apache_beam/runners/common.py", line 1406, in 
apache_beam.runners.common.DoFnRunner.process
   E           File "apache_beam/runners/common.py", line 1494, in 
apache_beam.runners.common.DoFnRunner._reraise_augmented
   E           File "apache_beam/runners/common.py", line 1404, in 
apache_beam.runners.common.DoFnRunner.process
   E           File "apache_beam/runners/common.py", line 624, in 
apache_beam.runners.common.SimpleInvoker.invoke_process
   E           File 
"/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python38/src/sdks/python/apache_beam/io/gcp/bigquery_json_it_test.py",
 line 103, in process
   E             self.assertEqual(country_expected, country_actual)
   E           File "/usr/local/lib/python3.8/unittest/case.py", line 911, in 
assertEqual
   E             assertion_func = self._getAssertEqualityFunc(first, second)
   E           File "/usr/local/lib/python3.8/unittest/case.py", line 892, in 
_getAssertEqualityFunc
   E             asserter = self._type_equality_funcs.get(type(first))
   E         AttributeError: 'CompareJson' object has no attribute 
'_type_equality_funcs' [while running 'Validate rows']
   
   apache_beam/runners/dataflow/dataflow_runner.py:1672: 
DataflowRuntimeException
   ```


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscr...@beam.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org