Release 1.11.6 (tracks 02ef28391649703e923f23e0d5cff72b595a8925)

Author: elementl-devtools

dagster-cloud-examples/dagster_cloud_examples/version.py

@@ -1 +1 @@
-__version__ = "1.11.5"
+__version__ = "1.11.6"

dagster-cloud-examples/pyproject.toml

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

dagster-cloud/dagster_cloud/agent/dagster_cloud_agent.py

@@ -12,8 +12,7 @@
 import dagster._check as check
 from dagster import DagsterInstance
 from dagster._core.launcher.base import LaunchRunContext
-from dagster._core.remote_representation import CodeLocationOrigin
-from dagster._core.remote_representation.origin import RegisteredCodeLocationOrigin
+from dagster._core.remote_origin import CodeLocationOrigin, RegisteredCodeLocationOrigin
 from dagster._core.utils import FuturesAwareThreadPoolExecutor
 from dagster._grpc.client import DagsterGrpcClient
 from dagster._grpc.types import CancelExecutionRequest

dagster-cloud/dagster_cloud/agent/instrumentation/schedule.py

@@ -1,6 +1,6 @@
 from dagster import deserialize_value
 from dagster._core.definitions.schedule_definition import ScheduleExecutionData
-from dagster._core.remote_representation import ScheduleExecutionErrorSnap
+from dagster._core.remote_representation.external_data import ScheduleExecutionErrorSnap
 
 from dagster_cloud.opentelemetry.observers.execution_observer import ExecutionObserverInstruments
 

dagster-cloud/dagster_cloud/agent/instrumentation/sensor.py

@@ -1,6 +1,6 @@
 from dagster import deserialize_value
 from dagster._core.definitions.sensor_definition import SensorExecutionData
-from dagster._core.remote_representation import SensorExecutionErrorSnap
+from dagster._core.remote_representation.external_data import SensorExecutionErrorSnap
 
 from dagster_cloud.opentelemetry.observers.execution_observer import ExecutionObserverInstruments
 

dagster-cloud/dagster_cloud/api/dagster_cloud_api.py

@@ -7,7 +7,8 @@
 from dagster._core.code_pointer import CodePointer
 from dagster._core.definitions.selector import JobSelector
 from dagster._core.events.log import EventLogEntry
-from dagster._core.remote_representation import CodeLocationOrigin, RepositorySnap
+from dagster._core.remote_origin import CodeLocationOrigin
+from dagster._core.remote_representation.external_data import RepositorySnap
 from dagster._core.storage.dagster_run import DagsterRun
 from dagster._core.utils import RequestUtilizationMetrics
 from dagster._record import IHaveNew, copy, record, record_custom

dagster-cloud/dagster_cloud/storage/runs/storage.py

@@ -13,7 +13,7 @@
 from dagster._core.events import DagsterEvent
 from dagster._core.execution.backfill import BulkActionsFilter, BulkActionStatus, PartitionBackfill
 from dagster._core.execution.telemetry import RunTelemetryData
-from dagster._core.remote_representation.origin import RemoteJobOrigin
+from dagster._core.remote_origin import RemoteJobOrigin
 from dagster._core.snap import ExecutionPlanSnapshot, JobSnap, create_execution_plan_snapshot_id
 from dagster._core.storage.dagster_run import (
     DagsterRun,

dagster-cloud/dagster_cloud/version.py

@@ -1 +1 @@
-__version__ = "1.11.5"
+__version__ = "1.11.6"

dagster-cloud/dagster_cloud/workspace/ecs/utils.py

@@ -2,7 +2,7 @@
 import re
 from typing import Optional
 
-from dagster._core.remote_representation.origin import RemoteJobOrigin
+from dagster._core.remote_origin import RemoteJobOrigin
 from dagster_aws.ecs.utils import sanitize_family
 
 from ..user_code_launcher.utils import get_human_readable_label, unique_resource_name

dagster-cloud/dagster_cloud/workspace/user_code_launcher/user_code_launcher.py

@@ -27,13 +27,13 @@
 from dagster._core.errors import DagsterUserCodeUnreachableError
 from dagster._core.instance import MayHaveInstanceWeakref
 from dagster._core.launcher import RunLauncher
-from dagster._core.remote_representation import RemoteRepositoryOrigin
-from dagster._core.remote_representation.external_data import (
-    extract_serialized_job_snap_from_serialized_job_data_snap,
-)
-from dagster._core.remote_representation.origin import (
+from dagster._core.remote_origin import (
     CodeLocationOrigin,
     RegisteredCodeLocationOrigin,
+    RemoteRepositoryOrigin,
+)
+from dagster._core.remote_representation.external_data import (
+    extract_serialized_job_snap_from_serialized_job_data_snap,
 )
 from dagster._grpc.client import DagsterGrpcClient
 from dagster._grpc.types import GetCurrentImageResult, ListRepositoriesResponse
@@ -1534,8 +1534,8 @@ def _trigger_recovery_server_restart(self, deployment_location: DeploymentAndLoc
             del self._first_unavailable_times[deployment_location]
 
         # redeploy the multipex server in this case as well to ensure a fresh start
-        # (and ensure that we don't try to create the same PexServerHandle again and
-        # delete the code location in a loop)
+        # if it resource contrained (and ensure that we don't try to create the same
+        # PexServerHandle again and delete the code location in a loop)
         if deployment_location in self._multipex_servers:
             del self._multipex_servers[deployment_location]
 
@@ -1568,11 +1568,11 @@ def _refresh_actual_entries(self) -> None:
                     if isinstance(grpc_server_or_error, DagsterCloudGrpcServer):
                         self._logger.warning(
                             "Pex servers disappeared for running code location %s:%s. Removing actual entries to"
-                            " activate reconciliation logic.",
+                            " activate reconciliation logic and deploy a new code server and multipex server.",
                             deployment_name,
                             location_name,
                         )
-                        del self._actual_entries[deployment_location]
+                        self._trigger_recovery_server_restart(deployment_location)
 
         # Check to see if any servers have become unresponsive
         unavailable_server_timeout = int(