Skip to content

Commit

Permalink
fixup
Browse files Browse the repository at this point in the history
  • Loading branch information
pabloem committed Nov 30, 2020
1 parent 551e026 commit f328870
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 1 deletion.
2 changes: 1 addition & 1 deletion sdks/python/apache_beam/io/gcp/bigquery_read_internal.py
Original file line number Diff line number Diff line change
Expand Up @@ -26,11 +26,11 @@
import logging
import random
import uuid
from typing import TYPE_CHECKING
from typing import Dict
from typing import Iterable
from typing import Optional
from typing import Union
from typing import TYPE_CHECKING

import apache_beam as beam
from apache_beam.coders import coders
Expand Down
1 change: 1 addition & 0 deletions sdks/python/apache_beam/io/gcp/bigquery_read_it_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -383,6 +383,7 @@ def create_bq_schema(cls, with_extra=False):
@skip(['PortableRunner', 'FlinkRunner'])
@attr('IT')
def test_read_queries(self):
# TODO(BEAM-11311): Remove experiment when tests run on r_v2.
args = self.args + ["--experiments=use_runner_v2"]
with beam.Pipeline(argv=args) as p:
result = (
Expand Down

0 comments on commit f328870

Please sign in to comment.