[BEAM-12303] Flake in PubSubIntegrationTest.test_streaming_with_attributes

• Type: Bug
• Status: Resolved
• Priority: P1
• Resolution: Cannot Reproduce
• Fix Version/s: Missing
• Component/s: io-py-gcp, test-failures
• Labels: flake
• Assignee: Unassigned
• Reporter: Brian Hulette
• Created: 06/May/21 22:49
• Updated: 13/Jan/22 21:49
• Resolved: 25/Aug/21 14:26

Description

Saw this recently in Python PostCommit: https://ci-beam.apache.org/job/beam_PostCommit_Python36/3862/testReport/junit/apache_beam.io.gcp.pubsub_integration_test/PubSubIntegrationTest/test_streaming_with_attributes/

Expected: (Test pipeline expected terminated in state: RUNNING and Expected 4 messages.)
     but: Expected 4 messages. Got 0 messages. Diffs (item, count):
  Expected but not in actual: dict_items([(PubsubMessage(b'data001-seen', {'processed': 'IT'}), 1), (PubsubMessage(b'data002-seen', {'timestamp_out': '2018-07-11T02:02:50.149000Z', 'processed': 'IT'}), 1), (PubsubMessage(b'data003\xab\xac-seen', {'processed': 'IT'}), 1), (PubsubMessage(b'data004\xab\xac-seen', {'timestamp_out': '2018-07-11T02:02:50.149000Z', 'processed': 'IT'}), 1)])
  Unexpected: dict_items([])
  Stripped attributes: ['id', 'timestamp']