We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f0505e6 commit 821db03Copy full SHA for 821db03
1 file changed
sdks/python/apache_beam/io/gcp/pubsub_integration_test.py
@@ -26,6 +26,8 @@
26
import uuid
27
28
import pytest
29
+from hamcrest.core.core.allof import all_of
30
+
31
from apache_beam.io.gcp import pubsub_it_pipeline
32
from apache_beam.io.gcp.pubsub import PubsubMessage
33
from apache_beam.io.gcp.pubsub import WriteToPubSub
@@ -34,7 +36,7 @@
34
36
from apache_beam.testing import test_utils
35
37
from apache_beam.testing.pipeline_verifiers import PipelineStateMatcher
38
from apache_beam.testing.test_pipeline import TestPipeline
-from hamcrest.core.core.allof import all_of
39
40
41
INPUT_TOPIC = 'psit_topic_input'
42
OUTPUT_TOPIC = 'psit_topic_output'
0 commit comments