See 
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/664/display/redirect?page=changes>

Changes:

[noreply] Remove spaces in experiments (#22423)


------------------------------------------
[...truncated 77.98 KB...]
INFO     
apache_beam.runners.dataflow.dataflow_runner:dataflow_runner.py:242 
2022-07-23T06:57:18.251Z: JOB_MESSAGE_DETAILED: Fusing consumer 
WriteAvgSessionLength/WriteToBigQuery/_StreamToBigQuery/DropShard into 
WriteAvgSessionLength/WriteToBigQuery/_StreamToBigQuery/CommitInsertIds/FlatMap(restore_timestamps)
INFO     
apache_beam.runners.dataflow.dataflow_runner:dataflow_runner.py:242 
2022-07-23T06:57:18.282Z: JOB_MESSAGE_DETAILED: Fusing consumer 
WriteAvgSessionLength/WriteToBigQuery/_StreamToBigQuery/FromHashableTableRef 
into WriteAvgSessionLength/WriteToBigQuery/_StreamToBigQuery/DropShard
INFO     
apache_beam.runners.dataflow.dataflow_runner:dataflow_runner.py:242 
2022-07-23T06:57:18.317Z: JOB_MESSAGE_DETAILED: Fusing consumer 
WriteAvgSessionLength/WriteToBigQuery/_StreamToBigQuery/StreamInsertRows/ParDo(BigQueryWriteFn)
 into 
WriteAvgSessionLength/WriteToBigQuery/_StreamToBigQuery/FromHashableTableRef
INFO     
apache_beam.runners.dataflow.dataflow_runner:dataflow_runner.py:242 
2022-07-23T06:57:18.491Z: JOB_MESSAGE_BASIC: Running job using Streaming Engine
INFO     
apache_beam.runners.dataflow.dataflow_runner:dataflow_runner.py:242 
2022-07-23T06:57:18.519Z: JOB_MESSAGE_BASIC: Using cloud KMLS key to protect 
persistent state.
INFO     
apache_beam.runners.dataflow.dataflow_runner:dataflow_runner.py:242 
2022-07-23T06:57:18.635Z: JOB_MESSAGE_DEBUG: Workflow config is missing a 
default resource spec.
INFO     
apache_beam.runners.dataflow.dataflow_runner:dataflow_runner.py:242 
2022-07-23T06:57:18.718Z: JOB_MESSAGE_DEBUG: Adding StepResource setup and 
teardown to workflow graph.
INFO     
apache_beam.runners.dataflow.dataflow_runner:dataflow_runner.py:242 
2022-07-23T06:57:18.750Z: JOB_MESSAGE_DEBUG: Adding workflow start and stop 
steps.
INFO     
apache_beam.runners.dataflow.dataflow_runner:dataflow_runner.py:242 
2022-07-23T06:57:18.783Z: JOB_MESSAGE_DEBUG: Assigning stage ids.
INFO     
apache_beam.runners.dataflow.dataflow_runner:dataflow_runner.py:242 
2022-07-23T06:57:18.844Z: JOB_MESSAGE_DEBUG: Starting worker pool setup.
INFO     
apache_beam.runners.dataflow.dataflow_runner:dataflow_runner.py:242 
2022-07-23T06:57:18.882Z: JOB_MESSAGE_BASIC: Starting 1 workers in 
us-central1-a...
INFO     
apache_beam.runners.dataflow.dataflow_runner:dataflow_runner.py:242 
2022-07-23T06:57:18.955Z: JOB_MESSAGE_DEBUG: Starting worker pool setup.
INFO     
apache_beam.runners.dataflow.dataflow_runner:dataflow_runner.py:242 
2022-07-23T06:57:38.843Z: JOB_MESSAGE_BASIC: Your project already contains 100 
Dataflow-created metric descriptors, so new user metrics of the form 
custom.googleapis.com/* will not be created. However, all user metrics are also 
available in the metric dataflow.googleapis.com/job/user_counter. If you rely 
on the custom metrics, you can delete old / unused metric descriptors. See 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.list
 and 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.delete
INFO     
apache_beam.runners.dataflow.dataflow_runner:dataflow_runner.py:242 
2022-07-23T06:57:55.106Z: JOB_MESSAGE_DETAILED: Autoscaling: Raised the number 
of workers to 1 so that the pipeline can catch up with its backlog and keep up 
with its input rate.
INFO     
apache_beam.runners.dataflow.dataflow_runner:dataflow_runner.py:242 
2022-07-23T06:58:23.642Z: JOB_MESSAGE_DETAILED: Workers have started 
successfully.
WARNING  
apache_beam.runners.dataflow.dataflow_runner:dataflow_runner.py:253 Timing out 
on waiting for job 2022-07-22_23_57_02-12652334270322494659 after 722 seconds
INFO     
apache_beam.io.gcp.tests.bigquery_matcher:bigquery_matcher.py:121 Attempting to 
perform query SELECT mean_duration FROM 
`apache-beam-testing.game_stats_it_dataset16585594167514.game_stats_sessions` 
WHERE mean_duration=300 LIMIT 1 to BQ
WARNING  apache_beam.utils.retry:retry.py:290 Retry with exponential 
backoff: waiting for 2.7716285381354453 seconds before retrying 
_query_with_retry because we caught exception: 
google.api_core.exceptions.NotFound: 404 Not found: Table 
apache-beam-testing:game_stats_it_dataset16585594167514.game_stats_sessions was 
not found in location US
                                              
                                              Location: US
                                              Job ID: 
86e8214b-dd5c-4b9a-aabe-6f105c4e1ad4
                                              
                                               Traceback for above exception 
(most recent call last):
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/utils/retry.py";,>
 line 275, in wrapper
                                                  return fun(*args, **kwargs)
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py";,>
 line 125, in _query_with_retry
                                                  rows = 
query_job.result(timeout=60)
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/cloud/bigquery/job/query.py";,>
 line 1499, in result
                                                  do_get_result()
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/api_core/retry.py";,>
 line 286, in retry_wrapped_func
                                                  return retry_target(
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/api_core/retry.py";,>
 line 189, in retry_target
                                                  return target()
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/cloud/bigquery/job/query.py";,>
 line 1489, in do_get_result
                                                  super(QueryJob, 
self).result(retry=retry, timeout=timeout)
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/cloud/bigquery/job/base.py";,>
 line 728, in result
                                                  return super(_AsyncJob, 
self).result(timeout=timeout, **kwargs)
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/api_core/future/polling.py";,>
 line 135, in result
                                                  raise self._exception
INFO     
apache_beam.io.gcp.tests.bigquery_matcher:bigquery_matcher.py:121 Attempting to 
perform query SELECT mean_duration FROM 
`apache-beam-testing.game_stats_it_dataset16585594167514.game_stats_sessions` 
WHERE mean_duration=300 LIMIT 1 to BQ
WARNING  apache_beam.utils.retry:retry.py:290 Retry with exponential 
backoff: waiting for 6.6854027226883295 seconds before retrying 
_query_with_retry because we caught exception: 
google.api_core.exceptions.NotFound: 404 Not found: Table 
apache-beam-testing:game_stats_it_dataset16585594167514.game_stats_sessions was 
not found in location US
                                              
                                              Location: US
                                              Job ID: 
dcaa033a-d7b7-469b-9f21-efe28230d99c
                                              
                                               Traceback for above exception 
(most recent call last):
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/utils/retry.py";,>
 line 275, in wrapper
                                                  return fun(*args, **kwargs)
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py";,>
 line 125, in _query_with_retry
                                                  rows = 
query_job.result(timeout=60)
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/cloud/bigquery/job/query.py";,>
 line 1499, in result
                                                  do_get_result()
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/api_core/retry.py";,>
 line 286, in retry_wrapped_func
                                                  return retry_target(
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/api_core/retry.py";,>
 line 189, in retry_target
                                                  return target()
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/cloud/bigquery/job/query.py";,>
 line 1489, in do_get_result
                                                  super(QueryJob, 
self).result(retry=retry, timeout=timeout)
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/cloud/bigquery/job/base.py";,>
 line 728, in result
                                                  return super(_AsyncJob, 
self).result(timeout=timeout, **kwargs)
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/api_core/future/polling.py";,>
 line 135, in result
                                                  raise self._exception
INFO     
apache_beam.io.gcp.tests.bigquery_matcher:bigquery_matcher.py:121 Attempting to 
perform query SELECT mean_duration FROM 
`apache-beam-testing.game_stats_it_dataset16585594167514.game_stats_sessions` 
WHERE mean_duration=300 LIMIT 1 to BQ
WARNING  apache_beam.utils.retry:retry.py:290 Retry with exponential 
backoff: waiting for 11.243248021534571 seconds before retrying 
_query_with_retry because we caught exception: 
google.api_core.exceptions.NotFound: 404 Not found: Table 
apache-beam-testing:game_stats_it_dataset16585594167514.game_stats_sessions was 
not found in location US
                                              
                                              Location: US
                                              Job ID: 
a6d0313f-28b1-4be0-b248-f5730680b5a1
                                              
                                               Traceback for above exception 
(most recent call last):
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/utils/retry.py";,>
 line 275, in wrapper
                                                  return fun(*args, **kwargs)
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py";,>
 line 125, in _query_with_retry
                                                  rows = 
query_job.result(timeout=60)
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/cloud/bigquery/job/query.py";,>
 line 1499, in result
                                                  do_get_result()
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/api_core/retry.py";,>
 line 286, in retry_wrapped_func
                                                  return retry_target(
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/api_core/retry.py";,>
 line 189, in retry_target
                                                  return target()
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/cloud/bigquery/job/query.py";,>
 line 1489, in do_get_result
                                                  super(QueryJob, 
self).result(retry=retry, timeout=timeout)
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/cloud/bigquery/job/base.py";,>
 line 728, in result
                                                  return super(_AsyncJob, 
self).result(timeout=timeout, **kwargs)
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/api_core/future/polling.py";,>
 line 135, in result
                                                  raise self._exception
INFO     
apache_beam.io.gcp.tests.bigquery_matcher:bigquery_matcher.py:121 Attempting to 
perform query SELECT mean_duration FROM 
`apache-beam-testing.game_stats_it_dataset16585594167514.game_stats_sessions` 
WHERE mean_duration=300 LIMIT 1 to BQ
WARNING  apache_beam.utils.retry:retry.py:290 Retry with exponential 
backoff: waiting for 20.75648759333836 seconds before retrying 
_query_with_retry because we caught exception: 
google.api_core.exceptions.NotFound: 404 Not found: Table 
apache-beam-testing:game_stats_it_dataset16585594167514.game_stats_sessions was 
not found in location US
                                              
                                              Location: US
                                              Job ID: 
f11a579e-f649-4960-b584-ea08acf3a59e
                                              
                                               Traceback for above exception 
(most recent call last):
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/utils/retry.py";,>
 line 275, in wrapper
                                                  return fun(*args, **kwargs)
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py";,>
 line 125, in _query_with_retry
                                                  rows = 
query_job.result(timeout=60)
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/cloud/bigquery/job/query.py";,>
 line 1499, in result
                                                  do_get_result()
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/api_core/retry.py";,>
 line 286, in retry_wrapped_func
                                                  return retry_target(
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/api_core/retry.py";,>
 line 189, in retry_target
                                                  return target()
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/cloud/bigquery/job/query.py";,>
 line 1489, in do_get_result
                                                  super(QueryJob, 
self).result(retry=retry, timeout=timeout)
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/cloud/bigquery/job/base.py";,>
 line 728, in result
                                                  return super(_AsyncJob, 
self).result(timeout=timeout, **kwargs)
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/api_core/future/polling.py";,>
 line 135, in result
                                                  raise self._exception
INFO     
apache_beam.io.gcp.tests.bigquery_matcher:bigquery_matcher.py:121 Attempting to 
perform query SELECT mean_duration FROM 
`apache-beam-testing.game_stats_it_dataset16585594167514.game_stats_sessions` 
WHERE mean_duration=300 LIMIT 1 to BQ
WARNING  apache_beam.utils.retry:retry.py:290 Retry with exponential 
backoff: waiting for 46.22656402578617 seconds before retrying 
_query_with_retry because we caught exception: 
google.api_core.exceptions.NotFound: 404 Not found: Table 
apache-beam-testing:game_stats_it_dataset16585594167514.game_stats_sessions was 
not found in location US
                                              
                                              Location: US
                                              Job ID: 
0cc8c818-5f6e-418c-bc3d-001c610c4194
                                              
                                               Traceback for above exception 
(most recent call last):
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/utils/retry.py";,>
 line 275, in wrapper
                                                  return fun(*args, **kwargs)
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py";,>
 line 125, in _query_with_retry
                                                  rows = 
query_job.result(timeout=60)
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/cloud/bigquery/job/query.py";,>
 line 1499, in result
                                                  do_get_result()
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/api_core/retry.py";,>
 line 286, in retry_wrapped_func
                                                  return retry_target(
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/api_core/retry.py";,>
 line 189, in retry_target
                                                  return target()
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/cloud/bigquery/job/query.py";,>
 line 1489, in do_get_result
                                                  super(QueryJob, 
self).result(retry=retry, timeout=timeout)
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/cloud/bigquery/job/base.py";,>
 line 728, in result
                                                  return super(_AsyncJob, 
self).result(timeout=timeout, **kwargs)
                                                File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/google/api_core/future/polling.py";,>
 line 135, in result
                                                  raise self._exception
INFO     
apache_beam.io.gcp.tests.bigquery_matcher:bigquery_matcher.py:121 Attempting to 
perform query SELECT mean_duration FROM 
`apache-beam-testing.game_stats_it_dataset16585594167514.game_stats_sessions` 
WHERE mean_duration=300 LIMIT 1 to BQ
=============================== warnings summary 
===============================
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/tenacity/_asyncio.py>:42
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/tenacity/_asyncio.py>:42
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/tenacity/_asyncio.py>:42
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/tenacity/_asyncio.py>:42
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/tenacity/_asyncio.py>:42
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/tenacity/_asyncio.py>:42
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/tenacity/_asyncio.py>:42
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/tenacity/_asyncio.py>:42
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/tenacity/_asyncio.py>:42:
 DeprecationWarning: "@coroutine" decorator is deprecated since Python 3.8, use 
"async def" instead
    def call(self, fn, *args, **kwargs):

apache_beam/dataframe/io.py:629
apache_beam/dataframe/io.py:629
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/dataframe/io.py>:629:
 FutureWarning: WriteToFiles is experimental.
    return pcoll | fileio.WriteToFiles(

apache_beam/io/fileio.py:581
apache_beam/io/fileio.py:581
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/io/fileio.py>:581:
 BeamDeprecationWarning: options is deprecated since First stable release. 
References to <pipeline>.options will not be supported
    p.options.view_as(GoogleCloudOptions).temp_location or

apache_beam/io/gcp/bigquery.py:2739
apache_beam/io/gcp/bigquery.py:2739
apache_beam/io/gcp/bigquery.py:2739
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2739:
 BeamDeprecationWarning: options is deprecated since First stable release. 
References to <pipeline>.options will not be supported
    temp_location = pcoll.pipeline.options.view_as(

apache_beam/io/gcp/bigquery.py:2741
apache_beam/io/gcp/bigquery.py:2741
apache_beam/io/gcp/bigquery.py:2741
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2741:
 BeamDeprecationWarning: options is deprecated since First stable release. 
References to <pipeline>.options will not be supported
    job_name = pcoll.pipeline.options.view_as(GoogleCloudOptions).job_name

apache_beam/io/gcp/bigquery.py:2765
apache_beam/io/gcp/bigquery.py:2765
apache_beam/io/gcp/bigquery.py:2765
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2765:
 BeamDeprecationWarning: options is deprecated since First stable release. 
References to <pipeline>.options will not be supported
    pipeline_options=pcoll.pipeline.options,

apache_beam/io/gcp/bigquery.py:2284
apache_beam/io/gcp/bigquery.py:2284
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2284:
 BeamDeprecationWarning: options is deprecated since First stable release. 
References to <pipeline>.options will not be supported
    self.table_reference.projectId = pcoll.pipeline.options.view_as(

apache_beam/io/gcp/bigquery.py:2288
apache_beam/io/gcp/bigquery.py:2288
apache_beam/io/gcp/bigquery.py:2288
apache_beam/io/gcp/bigquery.py:2288
apache_beam/io/gcp/bigquery.py:2288
apache_beam/io/gcp/bigquery.py:2288
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2288:
 BeamDeprecationWarning: options is deprecated since First stable release. 
References to <pipeline>.options will not be supported
    is_streaming_pipeline = p.options.view_as(StandardOptions).streaming

apache_beam/io/gcp/bigquery.py:2294
apache_beam/io/gcp/bigquery.py:2294
apache_beam/io/gcp/bigquery.py:2294
apache_beam/io/gcp/bigquery.py:2294
apache_beam/io/gcp/bigquery.py:2294
apache_beam/io/gcp/bigquery.py:2294
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2294:
 BeamDeprecationWarning: options is deprecated since First stable release. 
References to <pipeline>.options will not be supported
    experiments = p.options.view_as(DebugOptions).experiments or []

apache_beam/io/gcp/bigquery_file_loads.py:1129
apache_beam/io/gcp/bigquery_file_loads.py:1129
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py>:1129:
 BeamDeprecationWarning: options is deprecated since First stable release. 
References to <pipeline>.options will not be supported
    temp_location = p.options.view_as(GoogleCloudOptions).temp_location

apache_beam/io/gcp/bigquery_file_loads.py:1131
apache_beam/io/gcp/bigquery_file_loads.py:1131
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py>:1131:
 BeamDeprecationWarning: options is deprecated since First stable release. 
References to <pipeline>.options will not be supported
    p.options.view_as(GoogleCloudOptions).job_name or 'AUTOMATIC_JOB_NAME')

apache_beam/io/gcp/tests/utils.py:100
apache_beam/io/gcp/tests/utils.py:100
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/io/gcp/tests/utils.py>:100:
 PendingDeprecationWarning: Client.dataset is deprecated and will be removed in 
a future version. Use a string like 'my_project.my_dataset' or a 
cloud.google.bigquery.DatasetReference object, instead.
    table_ref = client.dataset(dataset_id).table(table_id)

apache_beam/io/gcp/tests/utils.py:63
apache_beam/io/gcp/tests/utils.py:63
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/io/gcp/tests/utils.py>:63:
 PendingDeprecationWarning: Client.dataset is deprecated and will be removed in 
a future version. Use a string like 'my_project.my_dataset' or a 
cloud.google.bigquery.DatasetReference object, instead.
    dataset_ref = client.dataset(unique_dataset_name, project=project)

apache_beam/examples/dataframe/flight_delays.py:47
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/apache_beam/examples/dataframe/flight_delays.py>:47:
 FutureWarning: Dropping of nuisance columns in DataFrame reductions (with 
'numeric_only=None') is deprecated; in a future version this will raise 
TypeError.  Select only valid columns before calling the reduction.
    return airline_df[at_top_airports].mean()

-- Docs: https://docs.pytest.org/en/latest/warnings.html
- generated xml file: 
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/pytest_postCommitIT-df-py39-xdist.xml>
 -
======== 1 failed, 16 passed, 3 skipped, 44 warnings in 1301.41 
seconds ========

> Task :sdks:python:test-suites:dataflow:py39:examples FAILED

FAILURE: Build failed with an exception.

* Where:
Script 
'<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/ws/src/sdks/python/test-suites/dataflow/common.gradle'>
 line: 187

* What went wrong:
Execution failed for task ':sdks:python:test-suites:dataflow:py39:examples'.
> Process 'command 'sh'' finished with non-zero exit value 1

* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
> Run with --scan to get full insights.

* Get more help at https://help.gradle.org

BUILD FAILED in 22m 43s
15 actionable tasks: 9 executed, 4 from cache, 2 up-to-date

Publishing build scan...
https://gradle.com/s/alttiqib5wdso

Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to