Release 1.11.13 (tracks 3e0c0d5ea29f65e44350256033ae4b40206ba485)

Author: elementl-devtools

dagster-cloud-examples/dagster_cloud_examples/version.py

@@ -1 +1 @@
-__version__ = "1.11.12"
+__version__ = "1.11.13"

dagster-cloud-examples/pyproject.toml

@@ -19,7 +19,7 @@ classifiers = [
     "Operating System :: OS Independent",
 ]
 dependencies = [
-    "dagster-cloud==1.11.12",
+    "dagster-cloud==1.11.13",
 ]
 
 [project.license]

dagster-cloud-examples/tox.ini

@@ -4,7 +4,7 @@ skipsdist = True
 
 [testenv]
 download = True
-install_command = /bin/bash {env:DAGSTER_INTERNAL_GIT_REPO_DIR}/scripts/uv-retry-install.sh {opts} {packages}
+install_command = uv pip install {opts} {packages}
 setenv =
   DD_DOGSTATSD_DISABLE = true
 passenv =

dagster-cloud/dagster_cloud/__init__.py

@@ -1,7 +1,7 @@
 from dagster._core.libraries import DagsterLibraryRegistry
 
-from .instance import DagsterCloudAgentInstance as DagsterCloudAgentInstance
-from .storage.compute_logs import CloudComputeLogManager as CloudComputeLogManager
-from .version import __version__
+from dagster_cloud.instance import DagsterCloudAgentInstance as DagsterCloudAgentInstance
+from dagster_cloud.storage.compute_logs import CloudComputeLogManager as CloudComputeLogManager
+from dagster_cloud.version import __version__
 
 DagsterLibraryRegistry.register("dagster-cloud", __version__)

dagster-cloud/dagster_cloud/agent/dagster_cloud_agent.py

@@ -31,6 +31,16 @@
 from dagster_cloud_cli.core.errors import DagsterCloudHTTPError, raise_http_error
 from dagster_cloud_cli.core.workspace import CodeLocationDeployData
 
+from dagster_cloud.agent.instrumentation.constants import DAGSTER_CLOUD_AGENT_METRIC_PREFIX
+from dagster_cloud.agent.instrumentation.run_launch import extract_run_attributes
+from dagster_cloud.agent.instrumentation.schedule import inspect_schedule_result
+from dagster_cloud.agent.instrumentation.sensor import inspect_sensor_result
+from dagster_cloud.agent.queries import (
+    ADD_AGENT_HEARTBEATS_MUTATION,
+    DEPLOYMENTS_QUERY,
+    GET_USER_CLOUD_REQUESTS_QUERY,
+    WORKSPACE_ENTRIES_QUERY,
+)
 from dagster_cloud.api.dagster_cloud_api import (
     AgentHeartbeat,
     AgentUtilizationMetrics,
@@ -48,26 +58,15 @@
 )
 from dagster_cloud.batching import Batcher
 from dagster_cloud.instance import DagsterCloudAgentInstance
+from dagster_cloud.opentelemetry.observers.execution_observer import observe_execution
+from dagster_cloud.util import SERVER_HANDLE_TAG, compressed_namedtuple_upload_file, is_isolated_run
+from dagster_cloud.version import __version__
 from dagster_cloud.workspace.user_code_launcher import (
     DagsterCloudUserCodeLauncher,
     UserCodeLauncherEntry,
 )
 from dagster_cloud.workspace.user_code_launcher.utils import get_instance_ref_for_user_code
 
-from ..opentelemetry.observers.execution_observer import observe_execution
-from ..util import SERVER_HANDLE_TAG, compressed_namedtuple_upload_file, is_isolated_run
-from ..version import __version__
-from .instrumentation.constants import DAGSTER_CLOUD_AGENT_METRIC_PREFIX
-from .instrumentation.run_launch import extract_run_attributes
-from .instrumentation.schedule import inspect_schedule_result
-from .instrumentation.sensor import inspect_sensor_result
-from .queries import (
-    ADD_AGENT_HEARTBEATS_MUTATION,
-    DEPLOYMENTS_QUERY,
-    GET_USER_CLOUD_REQUESTS_QUERY,
-    WORKSPACE_ENTRIES_QUERY,
-)
-
 if TYPE_CHECKING:
     import datetime
 

dagster-cloud/dagster_cloud/anomaly_detection/__init__.py

@@ -1,7 +1,7 @@
-from .defs import (
+from dagster_cloud.anomaly_detection.defs import (
     build_anomaly_detection_freshness_checks as build_anomaly_detection_freshness_checks,
 )
-from .types import (
+from dagster_cloud.anomaly_detection.types import (
     AnomalyDetectionModelParams as AnomalyDetectionModelParams,
     BetaFreshnessAnomalyDetectionParams as BetaFreshnessAnomalyDetectionParams,
 )

dagster-cloud/dagster_cloud/anomaly_detection/defs.py

@@ -39,8 +39,8 @@
     create_cloud_webserver_client,
 )
 
-from .mutation import ANOMALY_DETECTION_INFERENCE_MUTATION
-from .types import (
+from dagster_cloud.anomaly_detection.mutation import ANOMALY_DETECTION_INFERENCE_MUTATION
+from dagster_cloud.anomaly_detection.types import (
     AnomalyDetectionModelParams,
     BetaFreshnessAnomalyDetectionParams,
     FreshnessAnomalyDetectionResult,

dagster-cloud/dagster_cloud/batching/__init__.py

@@ -1 +1 @@
-from .batcher import Batcher as Batcher
+from dagster_cloud.batching.batcher import Batcher as Batcher

dagster-cloud/dagster_cloud/dagster_insights/__init__.py

@@ -1,24 +1,30 @@
 import sys
 from typing import Any
 
-from .snowflake.dbt_wrapper import dbt_with_snowflake_insights as dbt_with_snowflake_insights
-from .snowflake.definitions import (
+from dagster_cloud.dagster_insights.snowflake.dbt_wrapper import (
+    dbt_with_snowflake_insights as dbt_with_snowflake_insights,
+)
+from dagster_cloud.dagster_insights.snowflake.definitions import (
     create_snowflake_insights_asset_and_schedule as create_snowflake_insights_asset_and_schedule,
 )
-from .snowflake.snowflake_utils import meter_snowflake_query as meter_snowflake_query
+from dagster_cloud.dagster_insights.snowflake.snowflake_utils import (
+    meter_snowflake_query as meter_snowflake_query,
+)
 
 dagster_snowflake_req_imports = {"InsightsSnowflakeResource"}
 try:
-    from .snowflake.insights_snowflake_resource import (
+    from dagster_cloud.dagster_insights.snowflake.insights_snowflake_resource import (
         InsightsSnowflakeResource as InsightsSnowflakeResource,
     )
 except ImportError:
     pass
 
 dagster_bigquery_req_imports = {"InsightsBigQueryResource", "dbt_with_bigquery_insights"}
 try:
-    from .bigquery.dbt_wrapper import dbt_with_bigquery_insights as dbt_with_bigquery_insights
-    from .bigquery.insights_bigquery_resource import (
+    from dagster_cloud.dagster_insights.bigquery.dbt_wrapper import (
+        dbt_with_bigquery_insights as dbt_with_bigquery_insights,
+    )
+    from dagster_cloud.dagster_insights.bigquery.insights_bigquery_resource import (
         InsightsBigQueryResource as InsightsBigQueryResource,
     )
 except ImportError:

dagster-cloud/dagster_cloud/dagster_insights/bigquery/dbt_wrapper.py

@@ -18,8 +18,14 @@
 from dagster_dbt.version import __version__ as dagster_dbt_version
 from packaging import version
 
-from ..insights_utils import extract_asset_info_from_event, handle_raise_on_error
-from .bigquery_utils import build_bigquery_cost_metadata, marker_asset_key_for_job
+from dagster_cloud.dagster_insights.bigquery.bigquery_utils import (
+    build_bigquery_cost_metadata,
+    marker_asset_key_for_job,
+)
+from dagster_cloud.dagster_insights.insights_utils import (
+    extract_asset_info_from_event,
+    handle_raise_on_error,
+)
 
 if TYPE_CHECKING:
     from dbt.adapters.base.impl import BaseAdapter