temporarily skip tests impacted by data inconsistency

Author: danabens

tests/integ/sagemaker/lineage/conftest.py

@@ -709,9 +709,10 @@ def static_model_artifact(sagemaker_session, static_pipeline_execution_arn):
             )
         )
 
-    yield artifact.ModelArtifact.load(
-        artifacts[0]["ArtifactArn"], sagemaker_session=sagemaker_session
-    )
+    artifact_arn = artifacts[0]["ArtifactArn"]
+    logging.info(f"Using static model artifact {artifact_arn}")
+
+    yield artifact.ModelArtifact.load(artifact_arn, sagemaker_session=sagemaker_session)
 
 
 @pytest.fixture

tests/integ/sagemaker/lineage/test_artifact.py

@@ -102,6 +102,7 @@ def test_list_by_type(artifact_objs, sagemaker_session):
     assert artifact_names_listed[0] == expected_name
 
 
+@pytest.mark.skip("data inconsistency P61661075")
 def test_get_artifact(static_dataset_artifact):
     s3_uri = static_dataset_artifact.source.source_uri
     expected_artifact = static_dataset_artifact.s3_uri_artifacts(s3_uri=s3_uri)

tests/integ/sagemaker/lineage/test_dataset_artifact.py

@@ -13,6 +13,8 @@
 """This module contains code to test SageMaker ``DatasetArtifact``"""
 from __future__ import absolute_import
 
+import pytest
+
 
 def test_trained_models(
     dataset_artifact_associated_models,
@@ -27,6 +29,7 @@ def test_trained_models(
         assert model.destination_type == "Context"
 
 
+@pytest.mark.skip("data inconsistency P61661075")
 def test_endpoint_contexts(
     static_dataset_artifact,
 ):
@@ -37,6 +40,7 @@ def test_endpoint_contexts(
         assert context.context_type == "Endpoint"
 
 
+@pytest.mark.skip("data inconsistency P61661075")
 def test_get_upstream_datasets(static_dataset_artifact, sagemaker_session):
     artifacts_from_query = static_dataset_artifact.upstream_datasets()
     assert len(artifacts_from_query) > 0
@@ -45,6 +49,7 @@ def test_get_upstream_datasets(static_dataset_artifact, sagemaker_session):
         assert "artifact" in artifact.artifact_arn
 
 
+@pytest.mark.skip("data inconsistency P61661075")
 def test_get_down_datasets(static_dataset_artifact, sagemaker_session):
     artifacts_from_query = static_dataset_artifact.downstream_datasets()
     assert len(artifacts_from_query) > 0

tests/integ/sagemaker/lineage/test_endpoint_context.py

@@ -14,6 +14,8 @@
 from __future__ import absolute_import
 import time
 
+import pytest
+
 SLEEP_TIME_ONE_SECONDS = 1
 SLEEP_TIME_THREE_SECONDS = 3
 
@@ -38,6 +40,7 @@ def test_model_v2(endpoint_context_associate_with_model, model_obj, sagemaker_se
         assert model.properties == model_obj.properties
 
 
+@pytest.mark.skip("data inconsistency P61661075")
 def test_dataset_artifacts(static_endpoint_context):
     artifacts_from_query = static_endpoint_context.dataset_artifacts()
 
@@ -46,6 +49,7 @@ def test_dataset_artifacts(static_endpoint_context):
         assert artifact.artifact_type == "DataSet"
 
 
+@pytest.mark.skip("data inconsistency P61661075")
 def test_training_job_arns(
     static_endpoint_context,
 ):
@@ -56,6 +60,7 @@ def test_training_job_arns(
         assert "training-job" in arn
 
 
+@pytest.mark.skip("data inconsistency P61661075")
 def test_pipeline_execution_arn(static_endpoint_context, static_pipeline_execution_arn):
     pipeline_execution_arn = static_endpoint_context.pipeline_execution_arn()
 

tests/integ/sagemaker/lineage/test_lineage_trial_component.py

@@ -13,21 +13,26 @@
 """This module contains code to test SageMaker ``Trial Component``"""
 from __future__ import absolute_import
 
+import pytest
 
+
+@pytest.mark.skip("data inconsistency P61661075")
 def test_dataset_artifacts(static_training_job_trial_component):
     artifacts_from_query = static_training_job_trial_component.dataset_artifacts()
     assert len(artifacts_from_query) > 0
     for artifact in artifacts_from_query:
         assert artifact.artifact_type == "DataSet"
 
 
+@pytest.mark.skip("data inconsistency P61661075")
 def test_models(static_processing_job_trial_component):
     artifacts_from_query = static_processing_job_trial_component.models()
     assert len(artifacts_from_query) > 0
     for artifact in artifacts_from_query:
         assert artifact.artifact_type == "Model"
 
 
+@pytest.mark.skip("data inconsistency P61661075")
 def test_pipeline_execution_arn(static_training_job_trial_component, static_pipeline_execution_arn):
     pipeline_execution_arn = static_training_job_trial_component.pipeline_execution_arn()
     assert pipeline_execution_arn == static_pipeline_execution_arn

tests/integ/sagemaker/lineage/test_model_artifact.py

@@ -13,6 +13,8 @@
 """This module contains code to test SageMaker ``DatasetArtifact``"""
 from __future__ import absolute_import
 
+import pytest
+
 
 def test_endpoints(
     model_artifact_associated_endpoints,
@@ -38,6 +40,7 @@ def test_endpoint_contexts(
         assert context.context_type == "Endpoint"
 
 
+@pytest.mark.skip("data inconsistency P61661075")
 def test_dataset_artifacts(
     static_model_artifact,
 ):
@@ -48,6 +51,7 @@ def test_dataset_artifacts(
         assert artifact.artifact_type == "DataSet"
 
 
+@pytest.mark.skip("data inconsistency P61661075")
 def test_training_job_arns(
     static_model_artifact,
 ):

tests/integ/sagemaker/lineage/test_model_package_group_context.py

@@ -14,6 +14,7 @@
 from __future__ import absolute_import
 
 
+@pytest.mark.skip("data inconsistency P61661075")
 def test_pipeline_execution_arn(static_model_package_group_context, static_pipeline_execution_arn):
     pipeline_execution_arn = static_model_package_group_context.pipeline_execution_arn()