Release 1.13.5 (tracks c06a58b31e4ad0e3d82ac723be753398f134c5f8)

Author: elementl-devtools

dagster-cloud-examples/dagster_cloud_examples/version.py

@@ -1 +1 @@
-__version__ = "1.13.4"
+__version__ = "1.13.5"

dagster-cloud-examples/pyproject.toml

@@ -7,7 +7,7 @@ build-backend = "hatchling.build"
 [project]
 name = "dagster-cloud-examples"
 requires-python = ">=3.9,<3.13"
-version = "1.13.4"
+version = "1.13.5"
 authors = [
     { name = "Elementl", email = "hello@elementl.com" },
 ]
@@ -17,7 +17,7 @@ classifiers = [
     "Operating System :: OS Independent",
 ]
 dependencies = [
-    "dagster-cloud==1.13.4",
+    "dagster-cloud==1.13.5",
 ]
 
 [project.license]

dagster-cloud/dagster_cloud/agent/dagster_cloud_agent.py

@@ -259,7 +259,7 @@ def _update_agent_resource_limits(
 
         self._utilization_metrics["resource_limits"][
             user_code_launcher.user_code_deployment_type.value
-        ] = limits  # type: ignore
+        ] = limits  # pyright: ignore[reportGeneralTypeIssues]
 
     def _update_utilization_metrics(self, user_code_launcher: DagsterCloudUserCodeLauncher):
         container_utilization_metrics = retrieve_containerized_utilization_metrics(
@@ -298,8 +298,10 @@ def run_loop(
             # for old agents, and only will work if there's a single deployment in the org)
             result = self._instance.graphql_client.execute(DEPLOYMENT_INFO_QUERY)
             deployment_name = result["data"]["deploymentInfo"]["deploymentName"]
-            self._instance = self._exit_stack.enter_context(
-                DagsterInstance.from_ref(self._instance.ref_for_deployment(deployment_name))  # type: ignore  # (instance subclass)
+            self._instance = self._exit_stack.enter_context(  # ty: ignore[invalid-assignment]  # pyright: ignore[reportAttributeAccessIssue]
+                DagsterInstance.from_ref(
+                    self._instance.ref_for_deployment(deployment_name)
+                )  # (instance subclass)
             )
 
         self._check_initial_deployment_names()

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

@@ -23,5 +23,5 @@ def build_bigquery_cost_metadata(
         BIGQUERY_METADATA_SLOTS_MS: slots_ms,
     }
     if job_ids:
-        metadata[BIGQUERY_METADATA_JOB_IDS] = job_ids
+        metadata[BIGQUERY_METADATA_JOB_IDS] = job_ids  # ty: ignore[invalid-assignment]
     return metadata

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

@@ -167,7 +167,7 @@ def jaffle_shop_dbt_assets(
     cost_by_asset = defaultdict(list)
     try:
         with adapter.connection_named("dagster_insights:bigquery_cost"):
-            client: bigquery.Client = adapter.connections.get_thread_connection().handle  # pyright: ignore[reportAssignmentType]
+            client: bigquery.Client = adapter.connections.get_thread_connection().handle
 
             if (client.location or adapter.config.credentials.location) and client.project:
                 # we should populate the location/project from the client, and use that to determine

dagster-cloud/dagster_cloud/dagster_insights/snowflake/insights_snowflake_resource.py

@@ -63,7 +63,7 @@ def __init__(self, *args, asset_key: AssetKey | None = None, **kwargs) -> None:
         self._asset_key = asset_key
         super().__init__(*args, **kwargs)
 
-    def execute_string(  # pyright: ignore[reportIncompatibleMethodOverride], fix me!
+    def execute_string(  # ty: ignore[invalid-method-override], fix me!
         self,
         sql_text: str,
         remove_comments: bool = False,
@@ -79,7 +79,7 @@ def execute_string(  # pyright: ignore[reportIncompatibleMethodOverride], fix me
             **kwargs,
         )
 
-    def execute_stream(  # pyright: ignore[reportIncompatibleMethodOverride], fix me!
+    def execute_stream(  # ty: ignore[invalid-method-override], fix me!
         self,
         stream: StringIO,
         remove_comments: bool = False,

dagster-cloud/dagster_cloud/execution/cloud_run_launcher/k8s.py

@@ -5,5 +5,5 @@ class CloudK8sRunLauncher(K8sRunLauncher):
     # Avoid call to `count_resume_run_attempts`, since resuming runs is not currently
     # supported in cloud and the method makes repeated event log calls.
     @property
-    def supports_run_worker_crash_recovery(self):  # pyright: ignore[reportIncompatibleMethodOverride]
+    def supports_run_worker_crash_recovery(self):
         return False

dagster-cloud/dagster_cloud/execution/cloud_run_launcher/process.py

@@ -59,7 +59,7 @@ def join(self, timeout=30):
                 for run_id in self._run_ids
                 if (
                     self._instance.get_run_by_id(run_id)
-                    and not self._instance.get_run_by_id(run_id).is_finished  # pyright: ignore[reportOptionalMemberAccess]
+                    and not self._instance.get_run_by_id(run_id).is_finished  # ty: ignore[unresolved-attribute]
                 )
             ]
 

dagster-cloud/dagster_cloud/instance/__init__.py

@@ -226,7 +226,7 @@ def create_graphql_client(
         return create_agent_graphql_client(
             self.client_managed_retries_requests_session,
             self.dagster_cloud_graphql_url,
-            self._dagster_cloud_api_config,  # pyright: ignore[reportArgumentType]
+            self._dagster_cloud_api_config,
             scope=scope,
         )
 
@@ -309,7 +309,7 @@ def http_client(self):
         if self._http_client is None:
             self._http_client = create_agent_http_client(
                 self.client_managed_retries_requests_session,
-                self._dagster_cloud_api_config,  # pyright: ignore[reportArgumentType]
+                self._dagster_cloud_api_config,
                 scope=DagsterCloudInstanceScope.DEPLOYMENT,
             )
 
@@ -422,7 +422,7 @@ def dagster_cloud_code_location_update_result_url(self):
         return f"{self.dagster_cloud_url}/code_location_update_result"
 
     def dagster_cloud_api_headers(self, scope: DagsterCloudInstanceScope):
-        return get_agent_headers(self._dagster_cloud_api_config, scope=scope)  # pyright: ignore[reportArgumentType]
+        return get_agent_headers(self._dagster_cloud_api_config, scope=scope)
 
     @property
     def dagster_cloud_agent_token(self) -> str:
@@ -445,7 +445,7 @@ def dagster_cloud_api_timeout(self) -> int:
     def dagster_cloud_api_proxies(self) -> dict[str, str] | None:
         # Requests library modifies the proxies key so create a copy
         return (
-            self._dagster_cloud_api_config.get("proxies").copy()  # pyright: ignore[reportOptionalMemberAccess]
+            self._dagster_cloud_api_config.get("proxies").copy()
             if self._dagster_cloud_api_config.get("proxies")
             else {}
         )
@@ -598,22 +598,23 @@ def config_defaults(base_dir):
 
         empty_yaml = yaml.dump({})
 
-        defaults["run_storage"] = ConfigurableClassData(  # pyright: ignore[reportIndexIssue]
+        # `defaults` is typed `Mapping[...]` upstream but is a mutable dict at runtime.
+        defaults["run_storage"] = ConfigurableClassData(  # ty: ignore[invalid-assignment]
             "dagster_cloud.storage.runs",
             "GraphQLRunStorage",
             empty_yaml,
         )
-        defaults["event_log_storage"] = ConfigurableClassData(  # pyright: ignore[reportIndexIssue]
+        defaults["event_log_storage"] = ConfigurableClassData(  # ty: ignore[invalid-assignment]
             "dagster_cloud.storage.event_logs",
             "GraphQLEventLogStorage",
             empty_yaml,
         )
-        defaults["schedule_storage"] = ConfigurableClassData(  # pyright: ignore[reportIndexIssue]
+        defaults["schedule_storage"] = ConfigurableClassData(  # ty: ignore[invalid-assignment]
             "dagster_cloud.storage.schedules",
             "GraphQLScheduleStorage",
             empty_yaml,
         )
-        defaults["storage"] = ConfigurableClassData(  # pyright: ignore[reportIndexIssue]
+        defaults["storage"] = ConfigurableClassData(  # ty: ignore[invalid-assignment]
             module_name="dagster._core.storage.legacy_storage",
             class_name="CompositeStorage",
             config_yaml=yaml.dump(
@@ -638,15 +639,15 @@ def config_defaults(base_dir):
             ),
         )
 
-        defaults["compute_logs"] = ConfigurableClassData(  # pyright: ignore[reportIndexIssue]
+        defaults["compute_logs"] = ConfigurableClassData(  # ty: ignore[invalid-assignment]
             "dagster_cloud.storage.compute_logs", "CloudComputeLogManager", empty_yaml
         )
 
-        defaults["secrets"] = ConfigurableClassData(  # pyright: ignore[reportIndexIssue]
+        defaults["secrets"] = ConfigurableClassData(  # ty: ignore[invalid-assignment]
             "dagster_cloud.secrets", "DagsterCloudSecretsLoader", empty_yaml
         )
 
-        defaults["defs_state_storage"] = ConfigurableClassData(  # pyright: ignore[reportIndexIssue]
+        defaults["defs_state_storage"] = ConfigurableClassData(  # ty: ignore[invalid-assignment]
             "dagster_cloud.storage.defs_state", "GraphQLDefsStateStorage", empty_yaml
         )
 

dagster-cloud/dagster_cloud/metadata/source_code.py

@@ -36,7 +36,7 @@ def _locate_git_root() -> Path | None:
     elif code_origin.python_file:
         code_origin_filepath = code_origin.python_file
 
-    if not code_origin_filepath:  # pyright: ignore[reportPossiblyUnboundVariable]
+    if not code_origin_filepath:
         return None
     current_dir = Path(code_origin_filepath)
     for parent in current_dir.parents: