Traceback (most recent call last):
  File "/workspace/dataflow/flex-templates/streaming_beam/e2e_test.py", line 106, in test_flex_template_run
    rows = list(utils.bigquery_query(query))
  File "/workspace/dataflow/conftest.py", line 76, in bigquery_query
    for row in bigquery_client.query(query):
  File "/workspace/dataflow/flex-templates/streaming_beam/.nox/py-3-8/lib/python3.8/site-packages/google/cloud/bigquery/job/query.py", line 1495, in __iter__
    return iter(self.result())
  File "/workspace/dataflow/flex-templates/streaming_beam/.nox/py-3-8/lib/python3.8/site-packages/google/cloud/bigquery/job/query.py", line 1303, in result
    super(QueryJob, self).result(retry=retry, timeout=timeout)
  File "/workspace/dataflow/flex-templates/streaming_beam/.nox/py-3-8/lib/python3.8/site-packages/google/cloud/bigquery/job/base.py", line 679, in result
    return super(_AsyncJob, self).result(timeout=timeout, **kwargs)
  File "/workspace/dataflow/flex-templates/streaming_beam/.nox/py-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py", line 135, in result
    raise self._exception
google.api_core.exceptions.NotFound: 404 Not found: Table python-docs-samples-tests:dataflow_flex_templates_streaming_beam_d56ac4.output_table was not found in location US
(job ID: 64ec5c10-3021-4e55-a0ad-62968a7491e7)
                                -----Query Job SQL Follows-----                                    

|    .    |    .    |    .    |    .    |    .    |    .    |    .    |    .    |    .    |

1:SELECT * FROM python-docs-samples-tests.dataflow_flex_templates_streaming_beam_d56ac4.output_table

|    .    |    .    |    .    |    .    |    .    |    .    |    .    |    .    |    .    |