[docs] remove unused imports in examples/docs_snippets

Author: cmpadden

Diff for: examples/docs_snippets/docs_snippets/concepts/assets/asset_checks/factory.py

@@ -1,5 +1,4 @@
-from collections.abc import Mapping, Sequence
-from typing import Any
+from collections.abc import Mapping
 from unittest.mock import MagicMock
 
 from dagster import (

Diff for: examples/docs_snippets/docs_snippets/concepts/assets/asset_checks/test_asset_check.py

@@ -7,7 +7,6 @@ def orders(): ...
 
 # start
 
-import pandas as pd
 
 from dagster import AssetCheckResult, asset_check
 

Diff for: examples/docs_snippets/docs_snippets/concepts/assets/asset_input_managers.py

@@ -1,5 +1,3 @@
-from typing import List  # noqa: UP035
-
 import pandas as pd
 
 from dagster import AssetIn, Definitions, asset

Diff for: examples/docs_snippets/docs_snippets/concepts/assets/asset_input_managers_numpy.py

@@ -8,10 +8,8 @@
     ConfigurableIOManager,
     Definitions,
     InputContext,
-    IOManager,
     OutputContext,
     asset,
-    io_manager,
 )
 
 from .asset_input_managers import (

Diff for: examples/docs_snippets/docs_snippets/concepts/assets/asset_retry.py

@@ -1,11 +1,4 @@
-from dagster import (
-    AssetExecutionContext,
-    Backoff,
-    Jitter,
-    RetryPolicy,
-    RetryRequested,
-    asset,
-)
+from dagster import AssetExecutionContext, Backoff, Jitter, RetryPolicy, asset
 
 
 @asset(

Diff for: examples/docs_snippets/docs_snippets/concepts/assets/asset_testing.py

@@ -63,7 +63,7 @@ def test_uses_context():
 # end_test_with_context_asset
 
 
-from typing import Any, Dict  # noqa: UP035
+from typing import Any
 
 import requests
 

Diff for: examples/docs_snippets/docs_snippets/concepts/assets/code_versions.py

@@ -1,6 +1,6 @@
 import json
 
-from dagster import AssetSpec, MaterializeResult, Output, asset, multi_asset
+from dagster import AssetSpec, MaterializeResult, asset, multi_asset
 
 
 # start_single_asset

Diff for: examples/docs_snippets/docs_snippets/concepts/assets/cross_cl_code_location_2.py

@@ -2,7 +2,7 @@
 # code_location_2.py
 import json
 
-from dagster import AssetKey, Definitions, asset
+from dagster import Definitions, asset
 
 
 @asset(deps=["code_location_1_asset"])

Diff for: examples/docs_snippets/docs_snippets/concepts/assets/graph_backed_asset.py

@@ -1,13 +1,11 @@
 # ruff: isort: skip_file
 from dagster import (
-    AssetKey,
     load_assets_from_current_module,
     Out,
     Output,
     AssetSelection,
     define_asset_job,
     Definitions,
-    OpExecutionContext,
 )
 from unittest.mock import MagicMock
 

Diff for: examples/docs_snippets/docs_snippets/concepts/assets/multi_assets.py

@@ -47,7 +47,7 @@ def split_actions(context: AssetExecutionContext):
 # end_subsettable_multi_asset
 
 # start_asset_deps_multi_asset
-from dagster import AssetKey, AssetSpec, asset, multi_asset
+from dagster import AssetSpec, asset, multi_asset
 
 
 @asset

Diff for: examples/docs_snippets/docs_snippets/concepts/io_management/custom_io_manager.py

@@ -1,6 +1,5 @@
 # ruff: isort: skip_file
 
-from typing import List  # noqa: UP035
 from dagster import job, op
 
 
@@ -53,7 +52,6 @@ def load_input(self, context: InputContext):
 # start_io_manager_factory_marker
 
 from dagster import IOManager, ConfigurableIOManagerFactory, OutputContext, InputContext
-import requests
 
 
 class ExternalIOManager(IOManager):
@@ -98,7 +96,7 @@ def load_input(self, context: InputContext):
 # end_partitioned_marker
 
 # start_df_marker
-from dagster import ConfigurableIOManager, io_manager
+from dagster import ConfigurableIOManager
 
 
 class DataframeTableIOManager(ConfigurableIOManager):

Diff for: examples/docs_snippets/docs_snippets/concepts/io_management/load_custom_type_from_config.py

@@ -1,5 +1,5 @@
 # def_start_marker
-from typing import Dict, Union  # noqa: UP035
+from typing import Union
 
 from dagster import (
     DagsterTypeLoaderContext,

Diff for: examples/docs_snippets/docs_snippets/concepts/io_management/loading_multiple_upstream_partitions.py

@@ -1,5 +1,4 @@
 from datetime import datetime
-from typing import Dict  # noqa: UP035
 
 import pandas as pd
 

Diff for: examples/docs_snippets/docs_snippets/concepts/io_management/metadata.py

@@ -1,13 +1,4 @@
-from dagster import (
-    ConfigurableIOManager,
-    InputContext,
-    IOManager,
-    Out,
-    OutputContext,
-    io_manager,
-    job,
-    op,
-)
+from dagster import ConfigurableIOManager, InputContext, Out, OutputContext, job, op
 
 
 def connect():

Diff for: examples/docs_snippets/docs_snippets/concepts/metadata-tags/tags.py

@@ -1,4 +1,4 @@
-from dagster import asset, define_asset_job, graph, job, op, to_job
+from dagster import asset, define_asset_job, graph, job, op
 
 # start_asset_tags
 

Diff for: examples/docs_snippets/docs_snippets/concepts/ops_jobs_graphs/dynamic.py

@@ -162,7 +162,6 @@ def get_pages():
 
 # dyn_out_return_start
 from dagster import DynamicOut, DynamicOutput, op
-from typing import List  # noqa: UP035
 
 
 @op(out=DynamicOut())

Diff for: examples/docs_snippets/docs_snippets/concepts/ops_jobs_graphs/fan_in_job.py

@@ -1,6 +1,5 @@
 # start_marker
 
-from typing import List  # noqa: UP035
 
 from dagster import job, op
 

Diff for: examples/docs_snippets/docs_snippets/concepts/ops_jobs_graphs/graphs/fan_in_graph.py

@@ -1,6 +1,5 @@
 # start_marker
 
-from typing import List  # noqa: UP035
 
 from dagster import graph, op
 

Diff for: examples/docs_snippets/docs_snippets/concepts/ops_jobs_graphs/op_events.py

@@ -62,7 +62,6 @@ def my_metadata_output(context: OpExecutionContext) -> Output:
 
 # start_op_output_4
 from dagster import Output, op
-from typing import Tuple  # noqa: UP035
 
 
 # Using Output as type annotation without inner type

Diff for: examples/docs_snippets/docs_snippets/concepts/ops_jobs_graphs/ops.py

@@ -138,7 +138,6 @@ def return_annotation_op() -> int:
 # end_return_annotation
 # start_tuple_return
 from dagster import op
-from typing import Tuple  # noqa: UP035
 
 
 @op(out={"int_output": Out(), "str_output": Out()})
@@ -150,7 +149,6 @@ def my_multiple_output_annotation_op() -> tuple[int, str]:
 
 # start_single_output_tuple
 from dagster import op
-from typing import Tuple  # noqa: UP035
 
 
 @op

Diff for: examples/docs_snippets/docs_snippets/concepts/ops_jobs_graphs/unit_tests.py

@@ -227,8 +227,6 @@ def test_op_with_resource():
 
 # end_test_op_resource_marker
 
-from dagster import resource
-
 
 # start_test_job_with_config
 from dagster import RunConfig

Diff for: examples/docs_snippets/docs_snippets/concepts/partitions_schedules_sensors/sensors/asset_sensors.py

@@ -1,23 +1,11 @@
-from dagster import (
-    AssetSelection,
-    DailyPartitionsDefinition,
-    RunRequest,
-    SkipReason,
-    WeeklyPartitionsDefinition,
-    asset,
-    define_asset_job,
-    job,
-    multi_asset_sensor,
-)
+from dagster import RunRequest, SkipReason, asset, job
 
 
 @job
 def my_job():
     pass
 
 
-from typing import List  # noqa: UP035
-
 from dagster import Config
 
 

Diff for: examples/docs_snippets/docs_snippets/concepts/partitions_schedules_sensors/sensors/sensor_alert.py

@@ -178,7 +178,6 @@ def my_job_succeeds():
 # end_run_status_sensor_testing_marker
 
 from dagster import SensorDefinition
-from typing import List  # noqa: UP035
 
 my_jobs: list[SensorDefinition] = []
 

Diff for: examples/docs_snippets/docs_snippets/concepts/partitions_schedules_sensors/sensors/sensors.py

@@ -6,7 +6,6 @@
     DefaultSensorStatus,
     SkipReason,
     asset,
-    define_asset_job,
     JobSelector,
     CodeLocationSelector,
     DagsterRunStatus,

Diff for: examples/docs_snippets/docs_snippets/concepts/resources/pythonic_resources.py

@@ -47,7 +47,7 @@ def test_my_resource_with_nesting():
     test_my_resource_with_nesting()
 
 
-from typing import TYPE_CHECKING, Dict, Any  # noqa: UP035
+from typing import TYPE_CHECKING, Any
 
 
 def new_resources_assets_defs() -> "Definitions":
@@ -57,7 +57,7 @@ def new_resources_assets_defs() -> "Definitions":
     from dagster import ResourceParam
     import requests
 
-    from typing import Dict, Any  # noqa: UP035
+    from typing import Any
 
     @asset
     def data_from_url(data_url: ResourceParam[str]) -> dict[str, Any]:
@@ -740,10 +740,8 @@ def new_resource_on_sensor() -> None:
         ConfigurableResource,
         job,
         Definitions,
-        RunConfig,
     )
     import requests
-    from typing import List  # noqa: UP035
 
     class UsersAPI(ConfigurableResource):
         url: str
@@ -780,7 +778,7 @@ def process_new_users_sensor(
 
     # start_test_resource_on_sensor
 
-    from dagster import build_sensor_context, validate_run_config
+    from dagster import build_sensor_context
 
     def test_process_new_users_sensor():
         class FakeUsersAPI:
@@ -802,11 +800,9 @@ def new_resource_on_schedule() -> None:
         ConfigurableResource,
         job,
         RunRequest,
-        RunConfig,
         Definitions,
     )
     from datetime import datetime
-    from typing import List  # noqa: UP035
 
     class DateFormatter(ConfigurableResource):
         format: str
@@ -837,7 +833,7 @@ def process_data_schedule(
     # end_new_resource_on_schedule
     # start_test_resource_on_schedule
 
-    from dagster import build_schedule_context, validate_run_config
+    from dagster import build_schedule_context
 
     def test_process_data_schedule():
         context = build_schedule_context(

Diff for: examples/docs_snippets/docs_snippets/docs_beta/guides/automation/simple-sensor-example.py

@@ -1,5 +1,4 @@
 import random
-from typing import List  # noqa: UP035
 
 from dagster import (
     AssetExecutionContext,

Diff for: examples/docs_snippets/docs_snippets/docs_beta/guides/data-assets/passing-data-assets/passing-data-rewrite-assets.py

@@ -1,5 +1,3 @@
-from typing import List  # noqa: UP035
-
 from dagster import asset
 
 

Diff for: examples/docs_snippets/docs_snippets/guides/dagster/automating_pipelines/s3_sensor.py

@@ -5,12 +5,10 @@
     sensor,
     op,
     job,
-    build_sensor_context,
     RunRequest,
     SkipReason,
     OpExecutionContext,
 )
-import os
 
 
 @op(config_schema={"filename": str})

Diff for: examples/docs_snippets/docs_snippets/guides/dagster/automating_pipelines/vanilla_schedule.py

@@ -1,6 +1,5 @@
 # ruff: isort: skip_file
 
-from dagster import asset
 
 # vanilla_schedule_start
 

Diff for: examples/docs_snippets/docs_snippets/guides/dagster/dagster_pipes/databricks/databricks_asset_client.py

@@ -6,7 +6,7 @@
 
 from dagster_databricks import PipesDatabricksClient
 
-from dagster import AssetExecutionContext, Definitions, EnvVar, asset
+from dagster import AssetExecutionContext, Definitions, asset
 from databricks.sdk import WorkspaceClient
 from databricks.sdk.service import jobs
 

Diff for: examples/docs_snippets/docs_snippets/guides/dagster/dagster_pipes/ecs/dagster_code.py

@@ -1,10 +1,7 @@
 # start_asset_marker
-import os
 
 # dagster_glue_pipes.py
-import boto3
 from dagster_aws.pipes import PipesECSClient
-from docutils.nodes import entry
 
 from dagster import AssetExecutionContext, asset
 
@@ -25,7 +22,6 @@ def ecs_pipes_asset(context: AssetExecutionContext, pipes_ecs_client: PipesECSCl
 # start_definitions_marker
 
 from dagster import Definitions  # noqa
-from dagster_aws.pipes import PipesS3MessageReader
 
 
 defs = Definitions(

Diff for: examples/docs_snippets/docs_snippets/guides/dagster/dagster_pipes/ecs/task.py

@@ -1,8 +1,4 @@
-from dagster_pipes import (
-    PipesEnvVarParamsLoader,
-    PipesS3ContextLoader,
-    open_dagster_pipes,
-)
+from dagster_pipes import open_dagster_pipes
 
 
 def main():

Diff for: examples/docs_snippets/docs_snippets/guides/dagster/dagster_pipes/emr-containers/dagster_code.py

@@ -35,7 +35,7 @@ def emr_containers_asset(
 
 # start_definitions_marker
 import boto3
-from dagster_aws.pipes import PipesS3ContextInjector, PipesS3MessageReader
+from dagster_aws.pipes import PipesS3MessageReader
 
 from dagster import Definitions
 

Diff for: examples/docs_snippets/docs_snippets/guides/dagster/dagster_pipes/emr-serverless/dagster_code.py

@@ -1,7 +1,5 @@
 # start_asset_marker
-import os
 
-import boto3
 from dagster_aws.pipes import PipesEMRServerlessClient
 
 from dagster import AssetExecutionContext, asset