Release 1.10.21 (tracks 12cab7959a2f734dc561e96b09f1acdfd1a56f52)

Author: elementl-devtools

dagster-cloud-examples/dagster_cloud_examples/version.py

@@ -1 +1 @@
-__version__ = "1.10.20"
+__version__ = "1.10.21"

dagster-cloud-examples/pyproject.toml

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

dagster-cloud/dagster_cloud/pex/grpc/server/server.py

@@ -14,7 +14,7 @@
     DagsterApiServicer,
     add_DagsterApiServicer_to_server,
 )
-from dagster._grpc.client import DEFAULT_GRPC_TIMEOUT
+from dagster._grpc.client import DEFAULT_GRPC_TIMEOUT, DEFAULT_REPOSITORY_GRPC_TIMEOUT
 from dagster._grpc.server import server_termination_target
 from dagster._grpc.types import GetCurrentRunsResult, SensorExecutionArgs
 from dagster._grpc.utils import max_rx_bytes, max_send_bytes
@@ -201,7 +201,9 @@ def GetCurrentImage(self, request, context):
         return self._query("GetCurrentImage", request, context)
 
     def StreamingExternalRepository(self, request, context):
-        return self._streaming_query("StreamingExternalRepository", request, context)
+        return self._streaming_query(
+            "StreamingExternalRepository", request, context, timeout=DEFAULT_REPOSITORY_GRPC_TIMEOUT
+        )
 
     def Heartbeat(self, request, context):
         return self._query("Heartbeat", request, context)

dagster-cloud/dagster_cloud/version.py

@@ -1 +1 @@
-__version__ = "1.10.20"
+__version__ = "1.10.21"

dagster-cloud/dagster_cloud/workspace/config_schema/__init__.py

@@ -62,8 +62,21 @@ def process_workspace_config(workspace_config) -> dict[str, Any]:
             python_file = config.get("python_file")
             package_name = config.get("package_name")
             module_name = config.get("module_name")
+            autoload_defs_module_name = config.get("autoload_defs_module_name")
             check.invariant(
-                len([val for val in [python_file, package_name, module_name] if val]) == 1,
+                len(
+                    [
+                        val
+                        for val in [
+                            python_file,
+                            package_name,
+                            module_name,
+                            autoload_defs_module_name,
+                        ]
+                        if val
+                    ]
+                )
+                == 1,
                 "Must supply exactly one of a file name, a package name, or a module name",
             )
 
@@ -73,7 +86,8 @@ def process_workspace_config(workspace_config) -> dict[str, Any]:
             new_location = {
                 k: v
                 for k, v in location.items()
-                if k not in ("python_file", "package_name", "module_name")
+                if k
+                not in ("python_file", "package_name", "module_name", "autoload_defs_module_name")
             }
             new_location["code_source"] = {}
             if "python_file" in location:
@@ -82,6 +96,10 @@ def process_workspace_config(workspace_config) -> dict[str, Any]:
                 new_location["code_source"]["package_name"] = location["package_name"]
             elif "module_name" in location:
                 new_location["code_source"]["module_name"] = location["module_name"]
+            elif "autoload_defs_module_name" in location:
+                new_location["code_source"]["autoload_defs_module_name"] = location[
+                    "autoload_defs_module_name"
+                ]
 
             new_location["location_name"] = name
             updated_locations.append(new_location)
@@ -194,6 +212,10 @@ def process_workspace_config(workspace_config) -> dict[str, Any]:
                     config=str,
                     description="Python module containing the target Dagster repository.",
                 ),
+                "autoload_defs_module_name": Field(
+                    config=str,
+                    description="Python module to automatically load Dagster definitions from.",
+                ),
             },
         ),
         description="Python entry point for the code location.",
@@ -282,6 +304,11 @@ def process_workspace_config(workspace_config) -> dict[str, Any]:
         is_required=False,
         description="Python module containing the target Dagster repository.",
     ),
+    "autoload_defs_module_name": Field(
+        config=str,
+        is_required=False,
+        description="Python module to automatically load Dagster definitions from.",
+    ),
 }
 LEGACY_LOCATION_CONFIG_SCHEMA = Shape(fields=LEGACY_CONFIG_SCHEMA_FIELDS)
 LEGACY_NAMED_LOCATIONS_CONFIG_SCHEMA = Map(

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

@@ -125,4 +125,11 @@ def get_grpc_server_env(
             if code_location_deploy_data.executable_path
             else {}
         ),
+        **(
+            {
+                "DAGSTER_CLI_API_GRPC_AUTOLOAD_DEFS_MODULE_NAME": code_location_deploy_data.autoload_defs_module_name
+            }
+            if code_location_deploy_data.autoload_defs_module_name
+            else {}
+        ),
     }

dagster-cloud/pyproject.toml

@@ -29,9 +29,9 @@ classifiers = [
     "Operating System :: OS Independent",
 ]
 dependencies = [
-    "dagster==1.10.20",
-    "dagster-shared==1.10.20",
-    "dagster-cloud-cli==1.10.20",
+    "dagster==1.10.21",
+    "dagster-shared==1.10.21",
+    "dagster-cloud-cli==1.10.21",
     "opentelemetry-api>=1.27.0,<2",
     "opentelemetry-sdk>=1.27.0,<2",
     "opentelemetry-exporter-otlp-proto-grpc>=1.27.0,<2",
@@ -90,14 +90,14 @@ insights = [
 ]
 docker = [
     "docker",
-    "dagster-docker==0.26.20",
+    "dagster-docker==0.26.21",
 ]
 kubernetes = [
     "kubernetes",
-    "dagster-k8s==0.26.20",
+    "dagster-k8s==0.26.21",
 ]
 ecs = [
-    "dagster-aws==0.26.20",
+    "dagster-aws==0.26.21",
     "boto3",
 ]
 sandbox = [