See 
<https://ci-beam.apache.org/job/beam_PostCommit_Python39/2413/display/redirect>

Changes:


------------------------------------------
[...truncated 7.99 MB...]
apache_beam/ml/inference/xgboost_inference_it_test.py::XGBoostInference::test_iris_classification_numpy_single_batch
 
[gw0] SKIPPED 
apache_beam/ml/inference/xgboost_inference_it_test.py::XGBoostInference::test_iris_classification_numpy_single_batch
 
apache_beam/ml/inference/xgboost_inference_it_test.py::XGBoostInference::test_iris_classification_numpy_single_batch_large_model
 
[gw0] SKIPPED 
apache_beam/ml/inference/xgboost_inference_it_test.py::XGBoostInference::test_iris_classification_numpy_single_batch_large_model
 
apache_beam/ml/inference/xgboost_inference_it_test.py::XGBoostInference::test_iris_classification_pandas_multi_batch
 
[gw0] SKIPPED 
apache_beam/ml/inference/xgboost_inference_it_test.py::XGBoostInference::test_iris_classification_pandas_multi_batch
 
apache_beam/ml/inference/xgboost_inference_it_test.py::XGBoostInference::test_iris_classification_pandas_single_batch
 
[gw0] SKIPPED 
apache_beam/ml/inference/xgboost_inference_it_test.py::XGBoostInference::test_iris_classification_pandas_single_batch
 
apache_beam/ml/inference/xgboost_inference_it_test.py::XGBoostInference::test_iris_classification_scipy_multi_batch
 
[gw0] SKIPPED 
apache_beam/ml/inference/xgboost_inference_it_test.py::XGBoostInference::test_iris_classification_scipy_multi_batch
 
apache_beam/ml/inference/xgboost_inference_it_test.py::XGBoostInference::test_iris_classification_scipy_single_batch
 
[gw0] SKIPPED 
apache_beam/ml/inference/xgboost_inference_it_test.py::XGBoostInference::test_iris_classification_scipy_single_batch
 
[gw4] PASSED 
apache_beam/ml/inference/sklearn_inference_it_test.py::SklearnInference::test_sklearn_mnist_classification
 
apache_beam/ml/inference/sklearn_inference_it_test.py::SklearnInference::test_sklearn_mnist_classification_large_model
 
[gw6] PASSED 
apache_beam/ml/gcp/recommendations_ai_test_it.py::RecommendationAIIT::test_predict
 
apache_beam/ml/gcp/videointelligenceml_test_it.py::VideoIntelligenceMlTestIT::test_label_detection_with_video_context
 
[gw6] SKIPPED 
apache_beam/ml/gcp/videointelligenceml_test_it.py::VideoIntelligenceMlTestIT::test_label_detection_with_video_context
 
apache_beam/testing/test_stream_it_test.py::TestStreamIntegrationTests::test_basic_execution
 
[gw6] SKIPPED 
apache_beam/testing/test_stream_it_test.py::TestStreamIntegrationTests::test_basic_execution
 
apache_beam/testing/test_stream_it_test.py::TestStreamIntegrationTests::test_multiple_outputs
 
[gw6] SKIPPED 
apache_beam/testing/test_stream_it_test.py::TestStreamIntegrationTests::test_multiple_outputs
 
apache_beam/testing/test_stream_it_test.py::TestStreamIntegrationTests::test_multiple_outputs_with_watermark_advancement
 
[gw6] SKIPPED 
apache_beam/testing/test_stream_it_test.py::TestStreamIntegrationTests::test_multiple_outputs_with_watermark_advancement
 
[gw2] PASSED 
apache_beam/transforms/external_it_test.py::ExternalTransformIT::test_job_python_from_python_it
 
apache_beam/transforms/periodicsequence_it_test.py::PeriodicSequenceIT::test_periodicsequence_outputs_valid_watermarks_it
 
[gw2] SKIPPED 
apache_beam/transforms/periodicsequence_it_test.py::PeriodicSequenceIT::test_periodicsequence_outputs_valid_watermarks_it
 
[gw1] PASSED 
apache_beam/ml/gcp/visionml_test_it.py::VisionMlTestIT::test_text_detection_with_language_hint
 
apache_beam/ml/inference/pytorch_inference_it_test.py::PyTorchInference::test_torch_run_inference_bert_for_masked_lm
 
[gw1] SKIPPED 
apache_beam/ml/inference/pytorch_inference_it_test.py::PyTorchInference::test_torch_run_inference_bert_for_masked_lm
 
apache_beam/ml/inference/pytorch_inference_it_test.py::PyTorchInference::test_torch_run_inference_bert_for_masked_lm_large_model
 
[gw1] SKIPPED 
apache_beam/ml/inference/pytorch_inference_it_test.py::PyTorchInference::test_torch_run_inference_bert_for_masked_lm_large_model
 
apache_beam/ml/inference/pytorch_inference_it_test.py::PyTorchInference::test_torch_run_inference_coco_maskrcnn_resnet50_fpn
 
[gw1] SKIPPED 
apache_beam/ml/inference/pytorch_inference_it_test.py::PyTorchInference::test_torch_run_inference_coco_maskrcnn_resnet50_fpn
 
apache_beam/ml/inference/pytorch_inference_it_test.py::PyTorchInference::test_torch_run_inference_coco_maskrcnn_resnet50_fpn_v1_and_v2
 
[gw1] SKIPPED 
apache_beam/ml/inference/pytorch_inference_it_test.py::PyTorchInference::test_torch_run_inference_coco_maskrcnn_resnet50_fpn_v1_and_v2
 
apache_beam/ml/inference/pytorch_inference_it_test.py::PyTorchInference::test_torch_run_inference_imagenet_mobilenetv2
 
[gw1] SKIPPED 
apache_beam/ml/inference/pytorch_inference_it_test.py::PyTorchInference::test_torch_run_inference_imagenet_mobilenetv2
 
[gw3] PASSED 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadUsingStorageApiTests::test_iobase_source_with_column_selection
 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadUsingStorageApiTests::test_iobase_source_with_column_selection_and_row_restriction
 
[gw4] PASSED 
apache_beam/ml/inference/sklearn_inference_it_test.py::SklearnInference::test_sklearn_mnist_classification_large_model
 
apache_beam/ml/inference/sklearn_inference_it_test.py::SklearnInference::test_sklearn_regression
 
[gw5] PASSED 
apache_beam/io/gcp/datastore/v1new/datastore_write_it_test.py::DatastoreWriteIT::test_datastore_write_limit
 
apache_beam/io/gcp/healthcare/dicomio_integration_test.py::DICOMIoIntegrationTest::test_dicom_search_instances
 
[gw3] PASSED 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadUsingStorageApiTests::test_iobase_source_with_column_selection_and_row_restriction
 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadUsingStorageApiTests::test_iobase_source_with_column_selection_and_row_restriction_rows
 
[gw4] PASSED 
apache_beam/ml/inference/sklearn_inference_it_test.py::SklearnInference::test_sklearn_regression
 
[gw5] PASSED 
apache_beam/io/gcp/healthcare/dicomio_integration_test.py::DICOMIoIntegrationTest::test_dicom_search_instances
 
apache_beam/io/gcp/healthcare/dicomio_integration_test.py::DICOMIoIntegrationTest::test_dicom_store_instance_from_gcs
 
[gw7] PASSED 
apache_beam/io/gcp/bigquery_test.py::PubSubBigQueryIT::test_streaming_inserts 
apache_beam/io/gcp/bigquery_test.py::BigQueryFileLoadsIntegrationTests::test_avro_file_load
 
[gw3] PASSED 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadUsingStorageApiTests::test_iobase_source_with_column_selection_and_row_restriction_rows
 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadUsingStorageApiTests::test_iobase_source_with_native_datetime
 
[gw5] PASSED 
apache_beam/io/gcp/healthcare/dicomio_integration_test.py::DICOMIoIntegrationTest::test_dicom_store_instance_from_gcs
 
[gw7] PASSED 
apache_beam/io/gcp/bigquery_test.py::BigQueryFileLoadsIntegrationTests::test_avro_file_load
 
apache_beam/runners/dataflow/dataflow_exercise_metrics_pipeline_test.py::ExerciseMetricsPipelineTest::test_metrics_it
 
[gw7] SKIPPED 
apache_beam/runners/dataflow/dataflow_exercise_metrics_pipeline_test.py::ExerciseMetricsPipelineTest::test_metrics_it
 
[gw3] PASSED 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadUsingStorageApiTests::test_iobase_source_with_native_datetime
 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadUsingStorageApiTests::test_iobase_source_with_query
 
[gw3] PASSED 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadUsingStorageApiTests::test_iobase_source_with_query
 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadUsingStorageApiTests::test_iobase_source_with_query_and_filters
 
[gw3] PASSED 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadUsingStorageApiTests::test_iobase_source_with_query_and_filters
 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadUsingStorageApiTests::test_iobase_source_with_row_restriction
 
[gw3] PASSED 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadUsingStorageApiTests::test_iobase_source_with_row_restriction
 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadUsingStorageApiTests::test_iobase_source_with_very_selective_filters
 
[gw3] PASSED 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadUsingStorageApiTests::test_iobase_source_with_very_selective_filters
 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadNewTypesTests::test_iobase_source
 
[gw3] PASSED 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadNewTypesTests::test_iobase_source
 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadNewTypesTests::test_native_source
 
[gw3] PASSED 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadNewTypesTests::test_native_source
 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadAllBQTests::test_read_queries 
[gw3] PASSED 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadAllBQTests::test_read_queries 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadInteractiveRunnerTests::test_read_in_interactive_runner
 
[gw3] PASSED 
apache_beam/io/gcp/bigquery_read_it_test.py::ReadInteractiveRunnerTests::test_read_in_interactive_runner
 

=================================== FAILURES ===================================
________________ PubSubIntegrationTest.test_streaming_data_only 
________________
[gw5] linux -- Python 3.9.10 
<https://ci-beam.apache.org/job/beam_PostCommit_Python39/ws/src/build/gradleenv/-1734967050/bin/python3.9>

args = (name: 
"projects/apache-beam-testing/subscriptions/psit_subscription_output7e2f682d-f781-4ed0-b9d2-f1df3bb95a5d"
topic: 
"projects/apache-beam-testing/topics/psit_topic_output7e2f682d-f781-4ed0-b9d2-f1df3bb95a5d"
,)
kwargs = {'metadata': [('x-goog-request-params', 
'name=projects/apache-beam-testing/subscriptions/psit_subscription_output7e2f6...d0-b9d2-f1df3bb95a5d'),
 ('x-goog-api-client', 'gl-python/3.9.10 grpc/1.59.0 gax/2.12.0 gccl/2.18.4')], 
'timeout': 60.0}

    @functools.wraps(callable_)
    def error_remapped_callable(*args, **kwargs):
        try:
>           return callable_(*args, **kwargs)

../../build/gradleenv/-1734967050/lib/python3.9/site-packages/google/api_core/grpc_helpers.py:75:
 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
../../build/gradleenv/-1734967050/lib/python3.9/site-packages/grpc/_channel.py:1161:
 in __call__
    return _end_unary_response_blocking(state, call, False, None)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

state = <grpc._channel._RPCState object at 0x7fc8cfa02430>
call = <grpc._cython.cygrpc.SegregatedCall object at 0x7fc8cfc2d780>
with_call = False, deadline = None

    def _end_unary_response_blocking(
        state: _RPCState,
        call: cygrpc.SegregatedCall,
        with_call: bool,
        deadline: Optional[float],
    ) -> Union[ResponseType, Tuple[ResponseType, grpc.Call]]:
        if state.code is grpc.StatusCode.OK:
            if with_call:
                rendezvous = _MultiThreadedRendezvous(state, call, None, 
deadline)
                return state.response, rendezvous
            else:
                return state.response
        else:
>           raise _InactiveRpcError(state)  # pytype: disable=not-instantiable
E           grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC 
that terminated with:
E              status = StatusCode.DEADLINE_EXCEEDED
E              details = "Deadline Exceeded"
E              debug_error_string = "UNKNOWN:Deadline Exceeded 
{grpc_status:4, created_time:"2023-10-10T12:43:15.981133558+00:00"}"
E           >

../../build/gradleenv/-1734967050/lib/python3.9/site-packages/grpc/_channel.py:1004:
 _InactiveRpcError

The above exception was the direct cause of the following exception:

self = <apache_beam.io.gcp.pubsub_integration_test.PubSubIntegrationTest 
testMethod=test_streaming_data_only>

    def setUp(self):
      self.test_pipeline = TestPipeline(is_integration_test=True)
      self.runner_name = type(self.test_pipeline.runner).__name__
      self.project = self.test_pipeline.get_option('project')
      self.uuid = str(uuid.uuid4())
    
      # Set up PubSub environment.
      from google.cloud import pubsub
      self.pub_client = pubsub.PublisherClient()
      self.input_topic = self.pub_client.create_topic(
          name=self.pub_client.topic_path(self.project, INPUT_TOPIC + 
self.uuid))
      self.output_topic = self.pub_client.create_topic(
          name=self.pub_client.topic_path(self.project, OUTPUT_TOPIC + 
self.uuid))
    
      self.sub_client = pubsub.SubscriberClient()
      self.input_sub = self.sub_client.create_subscription(
          name=self.sub_client.subscription_path(
              self.project, INPUT_SUB + self.uuid),
          topic=self.input_topic.name)
>     self.output_sub = self.sub_client.create_subscription(
          name=self.sub_client.subscription_path(
              self.project, OUTPUT_SUB + self.uuid),
          topic=self.output_topic.name)

apache_beam/io/gcp/pubsub_integration_test.py:153: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
../../build/gradleenv/-1734967050/lib/python3.9/site-packages/google/pubsub_v1/services/subscriber/client.py:680:
 in create_subscription
    response = rpc(
../../build/gradleenv/-1734967050/lib/python3.9/site-packages/google/api_core/gapic_v1/method.py:131:
 in __call__
    return wrapped_func(*args, **kwargs)
../../build/gradleenv/-1734967050/lib/python3.9/site-packages/google/api_core/retry.py:366:
 in retry_wrapped_func
    return retry_target(
../../build/gradleenv/-1734967050/lib/python3.9/site-packages/google/api_core/retry.py:204:
 in retry_target
    return target()
../../build/gradleenv/-1734967050/lib/python3.9/site-packages/google/api_core/timeout.py:120:
 in func_with_timeout
    return func(*args, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

args = (name: 
"projects/apache-beam-testing/subscriptions/psit_subscription_output7e2f682d-f781-4ed0-b9d2-f1df3bb95a5d"
topic: 
"projects/apache-beam-testing/topics/psit_topic_output7e2f682d-f781-4ed0-b9d2-f1df3bb95a5d"
,)
kwargs = {'metadata': [('x-goog-request-params', 
'name=projects/apache-beam-testing/subscriptions/psit_subscription_output7e2f6...d0-b9d2-f1df3bb95a5d'),
 ('x-goog-api-client', 'gl-python/3.9.10 grpc/1.59.0 gax/2.12.0 gccl/2.18.4')], 
'timeout': 60.0}

    @functools.wraps(callable_)
    def error_remapped_callable(*args, **kwargs):
        try:
            return callable_(*args, **kwargs)
        except grpc.RpcError as exc:
>           raise exceptions.from_grpc_error(exc) from exc
E           google.api_core.exceptions.DeadlineExceeded: 504 Deadline 
Exceeded

../../build/gradleenv/-1734967050/lib/python3.9/site-packages/google/api_core/grpc_helpers.py:77:
 DeadlineExceeded
=============================== warnings summary 
===============================
../../build/gradleenv/-1734967050/lib/python3.9/site-packages/hdfs/config.py:28
../../build/gradleenv/-1734967050/lib/python3.9/site-packages/hdfs/config.py:28
../../build/gradleenv/-1734967050/lib/python3.9/site-packages/hdfs/config.py:28
../../build/gradleenv/-1734967050/lib/python3.9/site-packages/hdfs/config.py:28
../../build/gradleenv/-1734967050/lib/python3.9/site-packages/hdfs/config.py:28
../../build/gradleenv/-1734967050/lib/python3.9/site-packages/hdfs/config.py:28
../../build/gradleenv/-1734967050/lib/python3.9/site-packages/hdfs/config.py:28
../../build/gradleenv/-1734967050/lib/python3.9/site-packages/hdfs/config.py:28
../../build/gradleenv/-1734967050/lib/python3.9/site-packages/hdfs/config.py:28
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python39/ws/src/build/gradleenv/-1734967050/lib/python3.9/site-packages/hdfs/config.py>:28:
 DeprecationWarning: the imp module is deprecated in favour of importlib; see 
the module's documentation for alternative uses
    from imp import load_source

apache_beam/examples/complete/game/hourly_team_score_it_test.py::HourlyTeamScoreIT::test_hourly_team_score_it
apache_beam/examples/complete/game/game_stats_it_test.py::GameStatsIT::test_game_stats_it
apache_beam/examples/complete/game/leader_board_it_test.py::LeaderBoardIT::test_leader_board_it
apache_beam/io/gcp/bigquery_test.py::PubSubBigQueryIT::test_file_loads
apache_beam/io/gcp/bigquery_test.py::PubSubBigQueryIT::test_streaming_inserts
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python39/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/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python39/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/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python39/ws/src/sdks/python/apache_beam/examples/dataframe/flight_delays.py>:47:
 FutureWarning: The default value of numeric_only in DataFrame.mean is 
deprecated. In a future version, it will default to False. In addition, 
specifying 'numeric_only=None' is deprecated. Select only valid columns or 
specify the value of numeric_only to silence this warning.
    return airline_df[at_top_airports].mean()

apache_beam/io/gcp/bigquery_read_it_test.py::ReadTests::test_native_source
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python39/ws/src/sdks/python/apache_beam/io/gcp/bigquery_read_it_test.py>:170:
 BeamDeprecationWarning: BigQuerySource is deprecated since 2.25.0. Use 
ReadFromBigQuery instead.
    beam.io.BigQuerySource(query=self.query, use_standard_sql=True)))

apache_beam/io/gcp/bigquery_read_it_test.py::ReadNewTypesTests::test_native_source
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python39/ws/src/sdks/python/apache_beam/io/gcp/bigquery_read_it_test.py>:706:
 BeamDeprecationWarning: BigQuerySource is deprecated since 2.25.0. Use 
ReadFromBigQuery instead.
    beam.io.BigQuerySource(query=self.query, use_standard_sql=True)))

-- Docs: https://docs.pytest.org/en/stable/how-to/capture-warnings.html
- generated xml file: 
<https://ci-beam.apache.org/job/beam_PostCommit_Python39/ws/src/sdks/python/pytest_postCommitIT-df-py39.xml>
 -
=========================== short test summary info 
============================
FAILED 
apache_beam/io/gcp/pubsub_integration_test.py::PubSubIntegrationTest::test_streaming_data_only
 - google.api_core.exceptions.DeadlineExceeded: 504 Deadline Exceeded
====== 1 failed, 87 passed, 50 skipped, 
18 warnings in 7355.24s (2:02:35) ======

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

FAILURE: Build failed with an exception.

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

* What went wrong:
Execution failed for task ':sdks:python:test-suites:dataflow:py39:postCommitIT'.
> 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.
> Get more help at https://help.gradle.org.

Deprecated Gradle features were used in this build, making it incompatible with 
Gradle 9.0.

You can use '--warning-mode all' to show the individual deprecation warnings 
and determine if they come from your own scripts or plugins.

For more on this, please refer to 
https://docs.gradle.org/8.3/userguide/command_line_interface.html#sec:command_line_warnings
 in the Gradle documentation.

BUILD FAILED in 2h 8m 55s
219 actionable tasks: 155 executed, 60 from cache, 4 up-to-date

Publishing build scan...
https://ge.apache.org/s/qirmockqcezx2

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