From b5fbbcdadc84d23077f6db7cecb39fb8e3716ce6 Mon Sep 17 00:00:00 2001
From: Nicholas Schrock <schrockn@dagsterlabs.com>
Date: Fri, 29 Sep 2023 10:09:07 -0400
Subject: [PATCH] Eliminate dead code in dagster_pipes

---
 .../dagster-pipes/dagster_pipes/__init__.py   | 40 -------------------
 1 file changed, 40 deletions(-)

diff --git a/python_modules/dagster-pipes/dagster_pipes/__init__.py b/python_modules/dagster-pipes/dagster_pipes/__init__.py
index 38b3c025a4f94..dbe8c3275cb9e 100644
--- a/python_modules/dagster-pipes/dagster_pipes/__init__.py
+++ b/python_modules/dagster-pipes/dagster_pipes/__init__.py
@@ -19,7 +19,6 @@
     ClassVar,
     Dict,
     Generic,
-    Iterable,
     Iterator,
     Literal,
     Mapping,
@@ -197,14 +196,6 @@ def _assert_defined_partition_property(value: Optional[_T], key: str) -> _T:
     )
 
 
-# This should only be called under the precondition that the current steps targets assets.
-def _assert_single_partition(data: PipesContextData, key: str) -> None:
-    partition_key_range = data["partition_key_range"]
-    assert partition_key_range is not None
-    if partition_key_range["start"] != partition_key_range["end"]:
-        raise DagsterPipesError(f"`{key}` is undefined. Current step targets multiple partitions.")
-
-
 def _assert_defined_extra(extras: PipesExtras, key: str) -> Any:
     if key not in extras:
         raise DagsterPipesError(f"Extra `{key}` is undefined. Extras must be provided by user.")
@@ -253,37 +244,6 @@ def _assert_opt_env_param_type(
     return value
 
 
-def _assert_param_value(value: _T, expected_values: Iterable[_T], method: str, param: str) -> _T:
-    if value not in expected_values:
-        raise DagsterPipesError(
-            f"Invalid value for parameter `{param}` of `{method}`. Expected one of"
-            f" `{expected_values}`, got `{value}`."
-        )
-    return value
-
-
-def _assert_opt_param_value(
-    value: _T, expected_values: Sequence[_T], method: str, param: str
-) -> _T:
-    if value is not None and value not in expected_values:
-        raise DagsterPipesError(
-            f"Invalid value for parameter `{param}` of `{method}`. Expected one of"
-            f" `{expected_values}`, got `{value}`."
-        )
-    return value
-
-
-def _assert_param_json_serializable(value: _T, method: str, param: str) -> _T:
-    try:
-        json.dumps(value)
-    except (TypeError, OverflowError):
-        raise DagsterPipesError(
-            f"Invalid type for parameter `{param}` of `{method}`. Expected a JSON-serializable"
-            f" type, got `{type(value)}`."
-        )
-    return value
-
-
 _METADATA_VALUE_KEYS = frozenset(PipesMetadataValue.__annotations__.keys())