Git Product home page Git Product logo

Comments (10)

flaky-bot avatar flaky-bot commented on July 20, 2024

commit: d23999b
buildURL: Build Status, Sponge
status: failed

Test output
args = (parent: "projects/ucaip-sample-tests/locations/us-central1/metadataStores/default"
artifact {
  uri: "gs://tmpvrtxsdk...49/sklearn-model/instance.yaml"
            }
          }
        }
      }
    }
  }
}
artifact_id: "sklearn-model"
,)
kwargs = {'metadata': [('x-goog-request-params', 'parent=projects/ucaip-sample-tests/locations/us-central1/metadataStores/defau...0 gapic/1.35.0+top_google_constructor_method+google.cloud.aiplatform.metadata.metadata._ExperimentTracker.log_model')]}
@functools.wraps(callable_)
def error_remapped_callable(*args, **kwargs):
    try:
      return callable_(*args, **kwargs)

.nox/system-3-10/lib/python3.10/site-packages/google/api_core/grpc_helpers.py:65:


.nox/system-3-10/lib/python3.10/site-packages/grpc/_channel.py:946: in call
return _end_unary_response_blocking(state, call, False, None)


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

def _end_unary_response_blocking(state, call, with_call, deadline):
    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)

E grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
E status = StatusCode.ALREADY_EXISTS
E details = "Artifact with name projects/580378083368/locations/us-central1/metadataStores/default/artifacts/sklearn-model already exists"
E debug_error_string = "UNKNOWN:Error received from peer ipv4:108.177.98.95:443 {grpc_message:"Artifact with name projects/580378083368/locations/us-central1/metadataStores/default/artifacts/sklearn-model already exists", grpc_status:6, created_time:"2023-10-20T04:41:48.199495871+00:00"}"
E >

.nox/system-3-10/lib/python3.10/site-packages/grpc/_channel.py:849: _InactiveRpcError

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

self = <tests.system.aiplatform.test_experiments.TestExperiments object at 0x7fd36731c1c0>
shared_state = {'bucket': <Bucket: tmpvrtxsdk-e2e-ccc9a830-6281-4930-8684-98286d831b49>, 'resources': [<google.cloud.aiplatform.tenso...ccc9a830-6281-4930-8684-98286d831b49', 'storage_client': <google.cloud.storage.client.Client object at 0x7fd365300430>}

def test_log_model(self, shared_state):
    aiplatform.init(
        project=e2e_base._PROJECT,
        location=e2e_base._LOCATION,
        experiment=self._experiment_name,
    )
    aiplatform.start_run(_RUN, resume=True)

    train_x = np.array([[1, 1], [1, 2], [2, 2], [2, 3]])
    train_y = np.dot(train_x, np.array([1, 2])) + 3
    model = LinearRegression()
    model.fit(train_x, train_y)
  model_artifact = aiplatform.log_model(
        model=model,
        artifact_id="sklearn-model",
        uri=f"gs://{shared_state['staging_bucket_name']}/sklearn-model",
        input_example=train_x,
    )

tests/system/aiplatform/test_experiments.py:202:


google/cloud/aiplatform/metadata/metadata.py:698: in log_model
self.experiment_run.log_model(
google/cloud/aiplatform/metadata/experiment_run_resource.py:81: in wrapper
return method(self, *args, **kwargs)
google/cloud/aiplatform/metadata/experiment_run_resource.py:1234: in log_model
experiment_model = _models.save_model(
google/cloud/aiplatform/metadata/_models.py:520: in save_model
model_artifact.create(
google/cloud/aiplatform/metadata/schema/base_artifact.py:186: in create
new_artifact_instance = artifact.Artifact.create(
google/cloud/aiplatform/metadata/artifact.py:354: in create
return cls._create(
google/cloud/aiplatform/metadata/artifact.py:204: in _create
resource = cls._create_resource(
google/cloud/aiplatform/metadata/artifact.py:113: in _create_resource
return client.create_artifact(
google/cloud/aiplatform_v1/services/metadata_service/client.py:1178: in create_artifact
response = rpc(
.nox/system-3-10/lib/python3.10/site-packages/google/api_core/gapic_v1/method.py:113: in call
return wrapped_func(*args, **kwargs)


args = (parent: "projects/ucaip-sample-tests/locations/us-central1/metadataStores/default"
artifact {
uri: "gs://tmpvrtxsdk...49/sklearn-model/instance.yaml"
}
}
}
}
}
}
}
artifact_id: "sklearn-model"
,)
kwargs = {'metadata': [('x-goog-request-params', 'parent=projects/ucaip-sample-tests/locations/us-central1/metadataStores/defau...0 gapic/1.35.0+top_google_constructor_method+google.cloud.aiplatform.metadata.metadata._ExperimentTracker.log_model')]}

@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.AlreadyExists: 409 Artifact with name projects/580378083368/locations/us-central1/metadataStores/default/artifacts/sklearn-model already exists

.nox/system-3-10/lib/python3.10/site-packages/google/api_core/grpc_helpers.py:67: AlreadyExists

from python-aiplatform.

flaky-bot avatar flaky-bot commented on July 20, 2024

commit: 11e2913
buildURL: Build Status, Sponge
status: failed

Test output
args = (parent: "projects/ucaip-sample-tests/locations/us-central1/metadataStores/default"
artifact {
  uri: "gs://tmpvrtxsdk... key: "frameworkName"
      value {
        string_value: "sklearn"
      }
    }
  }
}
artifact_id: "sklearn-model"
,)
kwargs = {'metadata': [('x-goog-request-params', 'parent=projects/ucaip-sample-tests/locations/us-central1/metadataStores/defau...0 gapic/1.35.0+top_google_constructor_method+google.cloud.aiplatform.metadata.metadata._ExperimentTracker.log_model')]}
@functools.wraps(callable_)
def error_remapped_callable(*args, **kwargs):
    try:
      return callable_(*args, **kwargs)

.nox/system-3-11/lib/python3.11/site-packages/google/api_core/grpc_helpers.py:75:


.nox/system-3-11/lib/python3.11/site-packages/grpc/_channel.py:946: in call
return _end_unary_response_blocking(state, call, False, None)


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

def _end_unary_response_blocking(state, call, with_call, deadline):
    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)

E grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
E status = StatusCode.ALREADY_EXISTS
E details = "Artifact with name projects/580378083368/locations/us-central1/metadataStores/default/artifacts/sklearn-model already exists"
E debug_error_string = "UNKNOWN:Error received from peer ipv4:142.250.99.95:443 {grpc_message:"Artifact with name projects/580378083368/locations/us-central1/metadataStores/default/artifacts/sklearn-model already exists", grpc_status:6, created_time:"2023-10-20T19:36:19.25583858+00:00"}"
E >

.nox/system-3-11/lib/python3.11/site-packages/grpc/_channel.py:849: _InactiveRpcError

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

self = <tests.system.aiplatform.test_experiments.TestExperiments object at 0x7f0aff76d310>
shared_state = {'bucket': <Bucket: tmpvrtxsdk-e2e-00de0b4e-00b8-4060-b82c-20f3f88177e4>, 'resources': [<google.cloud.aiplatform.tenso...00de0b4e-00b8-4060-b82c-20f3f88177e4', 'storage_client': <google.cloud.storage.client.Client object at 0x7f0aec83a150>}

def test_log_model(self, shared_state):
    aiplatform.init(
        project=e2e_base._PROJECT,
        location=e2e_base._LOCATION,
        experiment=self._experiment_name,
    )
    aiplatform.start_run(_RUN, resume=True)

    train_x = np.array([[1, 1], [1, 2], [2, 2], [2, 3]])
    train_y = np.dot(train_x, np.array([1, 2])) + 3
    model = LinearRegression()
    model.fit(train_x, train_y)
  model_artifact = aiplatform.log_model(
        model=model,
        artifact_id="sklearn-model",
        uri=f"gs://{shared_state['staging_bucket_name']}/sklearn-model",
        input_example=train_x,
    )

tests/system/aiplatform/test_experiments.py:202:


google/cloud/aiplatform/metadata/metadata.py:698: in log_model
self.experiment_run.log_model(
google/cloud/aiplatform/metadata/experiment_run_resource.py:81: in wrapper
return method(self, *args, **kwargs)
google/cloud/aiplatform/metadata/experiment_run_resource.py:1234: in log_model
experiment_model = _models.save_model(
google/cloud/aiplatform/metadata/_models.py:520: in save_model
model_artifact.create(
google/cloud/aiplatform/metadata/schema/base_artifact.py:186: in create
new_artifact_instance = artifact.Artifact.create(
google/cloud/aiplatform/metadata/artifact.py:354: in create
return cls._create(
google/cloud/aiplatform/metadata/artifact.py:204: in _create
resource = cls._create_resource(
google/cloud/aiplatform/metadata/artifact.py:113: in _create_resource
return client.create_artifact(
google/cloud/aiplatform_v1/services/metadata_service/client.py:1178: in create_artifact
response = rpc(
.nox/system-3-11/lib/python3.11/site-packages/google/api_core/gapic_v1/method.py:131: in call
return wrapped_func(*args, **kwargs)


args = (parent: "projects/ucaip-sample-tests/locations/us-central1/metadataStores/default"
artifact {
uri: "gs://tmpvrtxsdk... key: "frameworkName"
value {
string_value: "sklearn"
}
}
}
}
artifact_id: "sklearn-model"
,)
kwargs = {'metadata': [('x-goog-request-params', 'parent=projects/ucaip-sample-tests/locations/us-central1/metadataStores/defau...0 gapic/1.35.0+top_google_constructor_method+google.cloud.aiplatform.metadata.metadata._ExperimentTracker.log_model')]}

@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.AlreadyExists: 409 Artifact with name projects/580378083368/locations/us-central1/metadataStores/default/artifacts/sklearn-model already exists

.nox/system-3-11/lib/python3.11/site-packages/google/api_core/grpc_helpers.py:77: AlreadyExists

from python-aiplatform.

flaky-bot avatar flaky-bot commented on July 20, 2024

commit: 1ff90ac
buildURL: Build Status, Sponge
status: failed

Test output
args = (parent: "projects/ucaip-sample-tests/locations/us-central1/metadataStores/default"
artifact {
  uri: "gs://tmpvrtxsdk...6d/sklearn-model/instance.yaml"
            }
          }
        }
      }
    }
  }
}
artifact_id: "sklearn-model"
,)
kwargs = {'metadata': [('x-goog-request-params', 'parent=projects/ucaip-sample-tests/locations/us-central1/metadataStores/defau...0 gapic/1.35.0+top_google_constructor_method+google.cloud.aiplatform.metadata.metadata._ExperimentTracker.log_model')]}
@functools.wraps(callable_)
def error_remapped_callable(*args, **kwargs):
    try:
      return callable_(*args, **kwargs)

.nox/system-3-10/lib/python3.10/site-packages/google/api_core/grpc_helpers.py:65:


.nox/system-3-10/lib/python3.10/site-packages/grpc/_channel.py:946: in call
return _end_unary_response_blocking(state, call, False, None)


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

def _end_unary_response_blocking(state, call, with_call, deadline):
    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)

E grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
E status = StatusCode.ALREADY_EXISTS
E details = "Artifact with name projects/580378083368/locations/us-central1/metadataStores/default/artifacts/sklearn-model already exists"
E debug_error_string = "UNKNOWN:Error received from peer ipv4:74.125.135.95:443 {created_time:"2023-10-21T07:27:35.362950232+00:00", grpc_status:6, grpc_message:"Artifact with name projects/580378083368/locations/us-central1/metadataStores/default/artifacts/sklearn-model already exists"}"
E >

.nox/system-3-10/lib/python3.10/site-packages/grpc/_channel.py:849: _InactiveRpcError

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

self = <tests.system.aiplatform.test_experiments.TestExperiments object at 0x7ff536ba6e30>
shared_state = {'bucket': <Bucket: tmpvrtxsdk-e2e-cd279f81-51b3-4985-9d75-b5ff224c396d>, 'resources': [<google.cloud.aiplatform.tenso...cd279f81-51b3-4985-9d75-b5ff224c396d', 'storage_client': <google.cloud.storage.client.Client object at 0x7ff51c00ba30>}

def test_log_model(self, shared_state):
    aiplatform.init(
        project=e2e_base._PROJECT,
        location=e2e_base._LOCATION,
        experiment=self._experiment_name,
    )
    aiplatform.start_run(_RUN, resume=True)

    train_x = np.array([[1, 1], [1, 2], [2, 2], [2, 3]])
    train_y = np.dot(train_x, np.array([1, 2])) + 3
    model = LinearRegression()
    model.fit(train_x, train_y)
  model_artifact = aiplatform.log_model(
        model=model,
        artifact_id="sklearn-model",
        uri=f"gs://{shared_state['staging_bucket_name']}/sklearn-model",
        input_example=train_x,
    )

tests/system/aiplatform/test_experiments.py:202:


google/cloud/aiplatform/metadata/metadata.py:698: in log_model
self.experiment_run.log_model(
google/cloud/aiplatform/metadata/experiment_run_resource.py:81: in wrapper
return method(self, *args, **kwargs)
google/cloud/aiplatform/metadata/experiment_run_resource.py:1234: in log_model
experiment_model = _models.save_model(
google/cloud/aiplatform/metadata/_models.py:520: in save_model
model_artifact.create(
google/cloud/aiplatform/metadata/schema/base_artifact.py:186: in create
new_artifact_instance = artifact.Artifact.create(
google/cloud/aiplatform/metadata/artifact.py:354: in create
return cls._create(
google/cloud/aiplatform/metadata/artifact.py:204: in _create
resource = cls._create_resource(
google/cloud/aiplatform/metadata/artifact.py:113: in _create_resource
return client.create_artifact(
google/cloud/aiplatform_v1/services/metadata_service/client.py:1178: in create_artifact
response = rpc(
.nox/system-3-10/lib/python3.10/site-packages/google/api_core/gapic_v1/method.py:113: in call
return wrapped_func(*args, **kwargs)


args = (parent: "projects/ucaip-sample-tests/locations/us-central1/metadataStores/default"
artifact {
uri: "gs://tmpvrtxsdk...6d/sklearn-model/instance.yaml"
}
}
}
}
}
}
}
artifact_id: "sklearn-model"
,)
kwargs = {'metadata': [('x-goog-request-params', 'parent=projects/ucaip-sample-tests/locations/us-central1/metadataStores/defau...0 gapic/1.35.0+top_google_constructor_method+google.cloud.aiplatform.metadata.metadata._ExperimentTracker.log_model')]}

@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.AlreadyExists: 409 Artifact with name projects/580378083368/locations/us-central1/metadataStores/default/artifacts/sklearn-model already exists

.nox/system-3-10/lib/python3.10/site-packages/google/api_core/grpc_helpers.py:67: AlreadyExists

from python-aiplatform.

flaky-bot avatar flaky-bot commented on July 20, 2024

commit: ffbd872
buildURL: Build Status, Sponge
status: failed

Test output
args = (parent: "projects/ucaip-sample-tests/locations/us-central1/metadataStores/default"
artifact {
  uri: "gs://tmpvrtxsdk...6e/sklearn-model/instance.yaml"
            }
          }
        }
      }
    }
  }
}
artifact_id: "sklearn-model"
,)
kwargs = {'metadata': [('x-goog-request-params', 'parent=projects/ucaip-sample-tests/locations/us-central1/metadataStores/defau...0 gapic/1.35.0+top_google_constructor_method+google.cloud.aiplatform.metadata.metadata._ExperimentTracker.log_model')]}
@functools.wraps(callable_)
def error_remapped_callable(*args, **kwargs):
    try:
      return callable_(*args, **kwargs)

.nox/system-3-10/lib/python3.10/site-packages/google/api_core/grpc_helpers.py:65:


.nox/system-3-10/lib/python3.10/site-packages/grpc/_channel.py:946: in call
return _end_unary_response_blocking(state, call, False, None)


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

def _end_unary_response_blocking(state, call, with_call, deadline):
    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)

E grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
E status = StatusCode.ALREADY_EXISTS
E details = "Artifact with name projects/580378083368/locations/us-central1/metadataStores/default/artifacts/sklearn-model already exists"
E debug_error_string = "UNKNOWN:Error received from peer ipv4:142.250.99.95:443 {grpc_message:"Artifact with name projects/580378083368/locations/us-central1/metadataStores/default/artifacts/sklearn-model already exists", grpc_status:6, created_time:"2023-10-23T19:07:01.068030393+00:00"}"
E >

.nox/system-3-10/lib/python3.10/site-packages/grpc/_channel.py:849: _InactiveRpcError

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

self = <tests.system.aiplatform.test_experiments.TestExperiments object at 0x7fe753e30af0>
shared_state = {'bucket': <Bucket: tmpvrtxsdk-e2e-b9ff8abb-d383-445a-b9af-0a2a1dd05d6e>, 'resources': [<google.cloud.aiplatform.tenso...b9ff8abb-d383-445a-b9af-0a2a1dd05d6e', 'storage_client': <google.cloud.storage.client.Client object at 0x7fe75207b190>}

def test_log_model(self, shared_state):
    aiplatform.init(
        project=e2e_base._PROJECT,
        location=e2e_base._LOCATION,
        experiment=self._experiment_name,
    )
    aiplatform.start_run(_RUN, resume=True)

    train_x = np.array([[1, 1], [1, 2], [2, 2], [2, 3]])
    train_y = np.dot(train_x, np.array([1, 2])) + 3
    model = LinearRegression()
    model.fit(train_x, train_y)
  model_artifact = aiplatform.log_model(
        model=model,
        artifact_id="sklearn-model",
        uri=f"gs://{shared_state['staging_bucket_name']}/sklearn-model",
        input_example=train_x,
    )

tests/system/aiplatform/test_experiments.py:202:


google/cloud/aiplatform/metadata/metadata.py:698: in log_model
self.experiment_run.log_model(
google/cloud/aiplatform/metadata/experiment_run_resource.py:81: in wrapper
return method(self, *args, **kwargs)
google/cloud/aiplatform/metadata/experiment_run_resource.py:1234: in log_model
experiment_model = _models.save_model(
google/cloud/aiplatform/metadata/_models.py:520: in save_model
model_artifact.create(
google/cloud/aiplatform/metadata/schema/base_artifact.py:186: in create
new_artifact_instance = artifact.Artifact.create(
google/cloud/aiplatform/metadata/artifact.py:354: in create
return cls._create(
google/cloud/aiplatform/metadata/artifact.py:204: in _create
resource = cls._create_resource(
google/cloud/aiplatform/metadata/artifact.py:113: in _create_resource
return client.create_artifact(
google/cloud/aiplatform_v1/services/metadata_service/client.py:1178: in create_artifact
response = rpc(
.nox/system-3-10/lib/python3.10/site-packages/google/api_core/gapic_v1/method.py:113: in call
return wrapped_func(*args, **kwargs)


args = (parent: "projects/ucaip-sample-tests/locations/us-central1/metadataStores/default"
artifact {
uri: "gs://tmpvrtxsdk...6e/sklearn-model/instance.yaml"
}
}
}
}
}
}
}
artifact_id: "sklearn-model"
,)
kwargs = {'metadata': [('x-goog-request-params', 'parent=projects/ucaip-sample-tests/locations/us-central1/metadataStores/defau...0 gapic/1.35.0+top_google_constructor_method+google.cloud.aiplatform.metadata.metadata._ExperimentTracker.log_model')]}

@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.AlreadyExists: 409 Artifact with name projects/580378083368/locations/us-central1/metadataStores/default/artifacts/sklearn-model already exists

.nox/system-3-10/lib/python3.10/site-packages/google/api_core/grpc_helpers.py:67: AlreadyExists

from python-aiplatform.

flaky-bot avatar flaky-bot commented on July 20, 2024

commit: 3d43497
buildURL: Build Status, Sponge
status: failed

Test output
args = (parent: "projects/ucaip-sample-tests/locations/us-central1/metadataStores/default"
artifact {
  uri: "gs://tmpvrtxsdk...d8/sklearn-model/instance.yaml"
            }
          }
        }
      }
    }
  }
}
artifact_id: "sklearn-model"
,)
kwargs = {'metadata': [('x-goog-request-params', 'parent=projects/ucaip-sample-tests/locations/us-central1/metadataStores/defau...0 gapic/1.35.0+top_google_constructor_method+google.cloud.aiplatform.metadata.metadata._ExperimentTracker.log_model')]}
@functools.wraps(callable_)
def error_remapped_callable(*args, **kwargs):
    try:
      return callable_(*args, **kwargs)

.nox/system-3-10/lib/python3.10/site-packages/google/api_core/grpc_helpers.py:65:


.nox/system-3-10/lib/python3.10/site-packages/grpc/_channel.py:946: in call
return _end_unary_response_blocking(state, call, False, None)


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

def _end_unary_response_blocking(state, call, with_call, deadline):
    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)

E grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
E status = StatusCode.ALREADY_EXISTS
E details = "Artifact with name projects/580378083368/locations/us-central1/metadataStores/default/artifacts/sklearn-model already exists"
E debug_error_string = "UNKNOWN:Error received from peer ipv4:142.250.107.95:443 {grpc_message:"Artifact with name projects/580378083368/locations/us-central1/metadataStores/default/artifacts/sklearn-model already exists", grpc_status:6, created_time:"2023-10-24T22:28:33.829160916+00:00"}"
E >

.nox/system-3-10/lib/python3.10/site-packages/grpc/_channel.py:849: _InactiveRpcError

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

self = <tests.system.aiplatform.test_experiments.TestExperiments object at 0x7fa8465d7220>
shared_state = {'bucket': <Bucket: tmpvrtxsdk-e2e-734d97cc-f17f-4ee3-8230-93a5176553d8>, 'resources': [<google.cloud.aiplatform.tenso...734d97cc-f17f-4ee3-8230-93a5176553d8', 'storage_client': <google.cloud.storage.client.Client object at 0x7fa844846e00>}

def test_log_model(self, shared_state):
    aiplatform.init(
        project=e2e_base._PROJECT,
        location=e2e_base._LOCATION,
        experiment=self._experiment_name,
    )
    aiplatform.start_run(_RUN, resume=True)

    train_x = np.array([[1, 1], [1, 2], [2, 2], [2, 3]])
    train_y = np.dot(train_x, np.array([1, 2])) + 3
    model = LinearRegression()
    model.fit(train_x, train_y)
  model_artifact = aiplatform.log_model(
        model=model,
        artifact_id="sklearn-model",
        uri=f"gs://{shared_state['staging_bucket_name']}/sklearn-model",
        input_example=train_x,
    )

tests/system/aiplatform/test_experiments.py:202:


google/cloud/aiplatform/metadata/metadata.py:698: in log_model
self.experiment_run.log_model(
google/cloud/aiplatform/metadata/experiment_run_resource.py:81: in wrapper
return method(self, *args, **kwargs)
google/cloud/aiplatform/metadata/experiment_run_resource.py:1234: in log_model
experiment_model = _models.save_model(
google/cloud/aiplatform/metadata/_models.py:520: in save_model
model_artifact.create(
google/cloud/aiplatform/metadata/schema/base_artifact.py:186: in create
new_artifact_instance = artifact.Artifact.create(
google/cloud/aiplatform/metadata/artifact.py:354: in create
return cls._create(
google/cloud/aiplatform/metadata/artifact.py:204: in _create
resource = cls._create_resource(
google/cloud/aiplatform/metadata/artifact.py:113: in _create_resource
return client.create_artifact(
google/cloud/aiplatform_v1/services/metadata_service/client.py:1178: in create_artifact
response = rpc(
.nox/system-3-10/lib/python3.10/site-packages/google/api_core/gapic_v1/method.py:113: in call
return wrapped_func(*args, **kwargs)


args = (parent: "projects/ucaip-sample-tests/locations/us-central1/metadataStores/default"
artifact {
uri: "gs://tmpvrtxsdk...d8/sklearn-model/instance.yaml"
}
}
}
}
}
}
}
artifact_id: "sklearn-model"
,)
kwargs = {'metadata': [('x-goog-request-params', 'parent=projects/ucaip-sample-tests/locations/us-central1/metadataStores/defau...0 gapic/1.35.0+top_google_constructor_method+google.cloud.aiplatform.metadata.metadata._ExperimentTracker.log_model')]}

@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.AlreadyExists: 409 Artifact with name projects/580378083368/locations/us-central1/metadataStores/default/artifacts/sklearn-model already exists

.nox/system-3-10/lib/python3.10/site-packages/google/api_core/grpc_helpers.py:67: AlreadyExists

from python-aiplatform.

flaky-bot avatar flaky-bot commented on July 20, 2024

commit: 8e42bc5
buildURL: Build Status, Sponge
status: failed

Test output
args = (parent: "projects/ucaip-sample-tests/locations/us-central1/metadataStores/default"
artifact {
  uri: "gs://tmpvrtxsdk...12/sklearn-model/instance.yaml"
            }
          }
        }
      }
    }
  }
}
artifact_id: "sklearn-model"
,)
kwargs = {'metadata': [('x-goog-request-params', 'parent=projects/ucaip-sample-tests/locations/us-central1/metadataStores/defau...0 gapic/1.35.0+top_google_constructor_method+google.cloud.aiplatform.metadata.metadata._ExperimentTracker.log_model')]}
@functools.wraps(callable_)
def error_remapped_callable(*args, **kwargs):
    try:
      return callable_(*args, **kwargs)

.nox/system-3-10/lib/python3.10/site-packages/google/api_core/grpc_helpers.py:65:


.nox/system-3-10/lib/python3.10/site-packages/grpc/_channel.py:946: in call
return _end_unary_response_blocking(state, call, False, None)


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

def _end_unary_response_blocking(state, call, with_call, deadline):
    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)

E grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
E status = StatusCode.ALREADY_EXISTS
E details = "Artifact with name projects/580378083368/locations/us-central1/metadataStores/default/artifacts/sklearn-model already exists"
E debug_error_string = "UNKNOWN:Error received from peer ipv4:74.125.197.95:443 {grpc_message:"Artifact with name projects/580378083368/locations/us-central1/metadataStores/default/artifacts/sklearn-model already exists", grpc_status:6, created_time:"2023-10-25T07:52:17.182800707+00:00"}"
E >

.nox/system-3-10/lib/python3.10/site-packages/grpc/_channel.py:849: _InactiveRpcError

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

self = <tests.system.aiplatform.test_experiments.TestExperiments object at 0x7f57984accd0>
shared_state = {'bucket': <Bucket: tmpvrtxsdk-e2e-7a1a6ab0-6a19-44b2-b4ba-ddeeff417f12>, 'resources': [<google.cloud.aiplatform.tenso...7a1a6ab0-6a19-44b2-b4ba-ddeeff417f12', 'storage_client': <google.cloud.storage.client.Client object at 0x7f5796647790>}

def test_log_model(self, shared_state):
    aiplatform.init(
        project=e2e_base._PROJECT,
        location=e2e_base._LOCATION,
        experiment=self._experiment_name,
    )
    aiplatform.start_run(_RUN, resume=True)

    train_x = np.array([[1, 1], [1, 2], [2, 2], [2, 3]])
    train_y = np.dot(train_x, np.array([1, 2])) + 3
    model = LinearRegression()
    model.fit(train_x, train_y)
  model_artifact = aiplatform.log_model(
        model=model,
        artifact_id="sklearn-model",
        uri=f"gs://{shared_state['staging_bucket_name']}/sklearn-model",
        input_example=train_x,
    )

tests/system/aiplatform/test_experiments.py:202:


google/cloud/aiplatform/metadata/metadata.py:698: in log_model
self.experiment_run.log_model(
google/cloud/aiplatform/metadata/experiment_run_resource.py:81: in wrapper
return method(self, *args, **kwargs)
google/cloud/aiplatform/metadata/experiment_run_resource.py:1234: in log_model
experiment_model = _models.save_model(
google/cloud/aiplatform/metadata/_models.py:520: in save_model
model_artifact.create(
google/cloud/aiplatform/metadata/schema/base_artifact.py:186: in create
new_artifact_instance = artifact.Artifact.create(
google/cloud/aiplatform/metadata/artifact.py:354: in create
return cls._create(
google/cloud/aiplatform/metadata/artifact.py:204: in _create
resource = cls._create_resource(
google/cloud/aiplatform/metadata/artifact.py:113: in _create_resource
return client.create_artifact(
google/cloud/aiplatform_v1/services/metadata_service/client.py:1178: in create_artifact
response = rpc(
.nox/system-3-10/lib/python3.10/site-packages/google/api_core/gapic_v1/method.py:113: in call
return wrapped_func(*args, **kwargs)


args = (parent: "projects/ucaip-sample-tests/locations/us-central1/metadataStores/default"
artifact {
uri: "gs://tmpvrtxsdk...12/sklearn-model/instance.yaml"
}
}
}
}
}
}
}
artifact_id: "sklearn-model"
,)
kwargs = {'metadata': [('x-goog-request-params', 'parent=projects/ucaip-sample-tests/locations/us-central1/metadataStores/defau...0 gapic/1.35.0+top_google_constructor_method+google.cloud.aiplatform.metadata.metadata._ExperimentTracker.log_model')]}

@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.AlreadyExists: 409 Artifact with name projects/580378083368/locations/us-central1/metadataStores/default/artifacts/sklearn-model already exists

.nox/system-3-10/lib/python3.10/site-packages/google/api_core/grpc_helpers.py:67: AlreadyExists

from python-aiplatform.

flaky-bot avatar flaky-bot commented on July 20, 2024

commit: 62e43d4
buildURL: Build Status, Sponge
status: failed

Test output
args = (parent: "projects/ucaip-sample-tests/locations/us-central1/metadataStores/default"
artifact {
  uri: "gs://tmpvrtxsdk...69/sklearn-model/instance.yaml"
            }
          }
        }
      }
    }
  }
}
artifact_id: "sklearn-model"
,)
kwargs = {'metadata': [('x-goog-request-params', 'parent=projects/ucaip-sample-tests/locations/us-central1/metadataStores/defau...0 gapic/1.35.0+top_google_constructor_method+google.cloud.aiplatform.metadata.metadata._ExperimentTracker.log_model')]}
@functools.wraps(callable_)
def error_remapped_callable(*args, **kwargs):
    try:
      return callable_(*args, **kwargs)

.nox/system-3-10/lib/python3.10/site-packages/google/api_core/grpc_helpers.py:65:


.nox/system-3-10/lib/python3.10/site-packages/grpc/_channel.py:946: in call
return _end_unary_response_blocking(state, call, False, None)


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

def _end_unary_response_blocking(state, call, with_call, deadline):
    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)

E grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
E status = StatusCode.ALREADY_EXISTS
E details = "Artifact with name projects/580378083368/locations/us-central1/metadataStores/default/artifacts/sklearn-model already exists"
E debug_error_string = "UNKNOWN:Error received from peer ipv4:74.125.195.95:443 {created_time:"2023-10-25T17:01:40.071405877+00:00", grpc_status:6, grpc_message:"Artifact with name projects/580378083368/locations/us-central1/metadataStores/default/artifacts/sklearn-model already exists"}"
E >

.nox/system-3-10/lib/python3.10/site-packages/grpc/_channel.py:849: _InactiveRpcError

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

self = <tests.system.aiplatform.test_experiments.TestExperiments object at 0x7fb209cf4a30>
shared_state = {'bucket': <Bucket: tmpvrtxsdk-e2e-7fdfa9cf-dc4e-4b76-9c13-f64fe3d99f69>, 'resources': [<google.cloud.aiplatform.tenso...7fdfa9cf-dc4e-4b76-9c13-f64fe3d99f69', 'storage_client': <google.cloud.storage.client.Client object at 0x7fb207d5e470>}

def test_log_model(self, shared_state):
    aiplatform.init(
        project=e2e_base._PROJECT,
        location=e2e_base._LOCATION,
        experiment=self._experiment_name,
    )
    aiplatform.start_run(_RUN, resume=True)

    train_x = np.array([[1, 1], [1, 2], [2, 2], [2, 3]])
    train_y = np.dot(train_x, np.array([1, 2])) + 3
    model = LinearRegression()
    model.fit(train_x, train_y)
  model_artifact = aiplatform.log_model(
        model=model,
        artifact_id="sklearn-model",
        uri=f"gs://{shared_state['staging_bucket_name']}/sklearn-model",
        input_example=train_x,
    )

tests/system/aiplatform/test_experiments.py:202:


google/cloud/aiplatform/metadata/metadata.py:698: in log_model
self.experiment_run.log_model(
google/cloud/aiplatform/metadata/experiment_run_resource.py:81: in wrapper
return method(self, *args, **kwargs)
google/cloud/aiplatform/metadata/experiment_run_resource.py:1234: in log_model
experiment_model = _models.save_model(
google/cloud/aiplatform/metadata/_models.py:520: in save_model
model_artifact.create(
google/cloud/aiplatform/metadata/schema/base_artifact.py:186: in create
new_artifact_instance = artifact.Artifact.create(
google/cloud/aiplatform/metadata/artifact.py:354: in create
return cls._create(
google/cloud/aiplatform/metadata/artifact.py:204: in _create
resource = cls._create_resource(
google/cloud/aiplatform/metadata/artifact.py:113: in _create_resource
return client.create_artifact(
google/cloud/aiplatform_v1/services/metadata_service/client.py:1178: in create_artifact
response = rpc(
.nox/system-3-10/lib/python3.10/site-packages/google/api_core/gapic_v1/method.py:113: in call
return wrapped_func(*args, **kwargs)


args = (parent: "projects/ucaip-sample-tests/locations/us-central1/metadataStores/default"
artifact {
uri: "gs://tmpvrtxsdk...69/sklearn-model/instance.yaml"
}
}
}
}
}
}
}
artifact_id: "sklearn-model"
,)
kwargs = {'metadata': [('x-goog-request-params', 'parent=projects/ucaip-sample-tests/locations/us-central1/metadataStores/defau...0 gapic/1.35.0+top_google_constructor_method+google.cloud.aiplatform.metadata.metadata._ExperimentTracker.log_model')]}

@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.AlreadyExists: 409 Artifact with name projects/580378083368/locations/us-central1/metadataStores/default/artifacts/sklearn-model already exists

.nox/system-3-10/lib/python3.10/site-packages/google/api_core/grpc_helpers.py:67: AlreadyExists

from python-aiplatform.

flaky-bot avatar flaky-bot commented on July 20, 2024

Test passed for commit 50f857f (Build Status, Sponge)! Closing this issue.

from python-aiplatform.

flaky-bot avatar flaky-bot commented on July 20, 2024

Looks like this issue is flaky. 😟

I'm going to leave this open and stop commenting.

A human should fix and close this.


commit: 0b825c9
buildURL: Build Status, Sponge
status: failed

Test output
self = 
shared_state = {'bucket': , 'resources': [}
def test_log_model(self, shared_state):
    aiplatform.init(
        project=e2e_base._PROJECT,
        location=e2e_base._LOCATION,
        experiment=self._experiment_name,
    )
    aiplatform.start_run(_RUN, resume=True)

    train_x = np.array([[1, 1], [1, 2], [2, 2], [2, 3]])
    train_y = np.dot(train_x, np.array([1, 2])) + 3
    model = LinearRegression()
    model.fit(train_x, train_y)

    try:
        model_artifact = aiplatform.log_model(
            model=model,
            artifact_id="sklearn-model",
            uri=f"gs://{shared_state['staging_bucket_name']}/sklearn-model",
            input_example=train_x,
        )
        shared_state["resources"].append(model_artifact)

        run = aiplatform.ExperimentRun(
            run_name=_RUN, experiment=self._experiment_name
        )
        experiment_model = run.get_experiment_models()[0]
        assert experiment_model.name == "sklearn-model"
        assert (
            experiment_model.uri
            == f"gs://{shared_state['staging_bucket_name']}/sklearn-model"
        )
        assert experiment_model.get_model_info() == {
            "model_class": "sklearn.linear_model._base.LinearRegression",
            "framework_name": "sklearn",
            "framework_version": sklearn.__version__,
            "input_example": {
                "type": "numpy.ndarray",
                "data": train_x.tolist(),
            },
        }
        experiment_model.delete()
    finally:
        # Make sure that, if the model resources already exists but the call
        # aiplatform.log_model fails, we clean up the model resource.
        run = aiplatform.ExperimentRun(
            run_name=_RUN, experiment=self._experiment_name
        )
      experiment_model = run.get_experiment_models()[0]

E IndexError: list index out of range

tests/system/aiplatform/test_experiments.py:236: IndexError

from python-aiplatform.

flaky-bot avatar flaky-bot commented on July 20, 2024

Oops! Looks like this issue is still flaky. It failed again. 😬

I reopened the issue, but a human will need to close it again.


commit: 792b8a9
buildURL: Build Status, Sponge
status: failed

Test output
self = 
shared_state = {'bucket': , 'resources': [}
def test_log_model(self, shared_state):
    aiplatform.init(
        project=e2e_base._PROJECT,
        location=e2e_base._LOCATION,
        experiment=self._experiment_name,
    )
    aiplatform.start_run(_RUN, resume=True)

    train_x = np.array([[1, 1], [1, 2], [2, 2], [2, 3]])
    train_y = np.dot(train_x, np.array([1, 2])) + 3
    model = LinearRegression()
    model.fit(train_x, train_y)

    model_artifact = aiplatform.log_model(
        model=model,
        artifact_id=self._experiment_model_name,
        uri=f"gs://{shared_state['staging_bucket_name']}/sklearn-model",
        input_example=train_x,
    )
    shared_state["resources"].append(model_artifact)

    run = aiplatform.ExperimentRun(run_name=_RUN, experiment=self._experiment_name)
    experiment_model = run.get_experiment_models()[0]
  assert experiment_model.name == "sklearn-model"

E AssertionError: assert 'tmpvrtxsdk-e...9-aa185032c09' == 'sklearn-model'
E - sklearn-model
E + tmpvrtxsdk-e2e-sklearn-model-0f58454f-08c9-469b-b279-aa185032c09

tests/system/aiplatform/test_experiments.py:213: AssertionError

from python-aiplatform.

Related Issues (20)

Recommend Projects

  • React photo React

    A declarative, efficient, and flexible JavaScript library for building user interfaces.

  • Vue.js photo Vue.js

    🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.

  • Typescript photo Typescript

    TypeScript is a superset of JavaScript that compiles to clean JavaScript output.

  • TensorFlow photo TensorFlow

    An Open Source Machine Learning Framework for Everyone

  • Django photo Django

    The Web framework for perfectionists with deadlines.

  • D3 photo D3

    Bring data to life with SVG, Canvas and HTML. 📊📈🎉

Recommend Topics

  • javascript

    JavaScript (JS) is a lightweight interpreted programming language with first-class functions.

  • web

    Some thing interesting about web. New door for the world.

  • server

    A server is a program made to process requests and deliver data to clients.

  • Machine learning

    Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.

  • Game

    Some thing interesting about game, make everyone happy.

Recommend Org

  • Facebook photo Facebook

    We are working to build community through open source technology. NB: members must have two-factor auth.

  • Microsoft photo Microsoft

    Open source projects and samples from Microsoft.

  • Google photo Google

    Google ❤️ Open Source for everyone.

  • D3 photo D3

    Data-Driven Documents codes.