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 b2fa5a0 commit 5e4f7ccCopy full SHA for 5e4f7cc
1 file changed
sdks/python/apache_beam/io/gcp/pubsub_integration_test.py
@@ -26,8 +26,6 @@
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
@@ -36,6 +34,7 @@
36
34
from apache_beam.testing import test_utils
37
35
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
INPUT_TOPIC = 'psit_topic_input'
41
OUTPUT_TOPIC = 'psit_topic_output'
0 commit comments