From 2a6d9546a0c8f8b801db0aaea4e942ba04d5d036 Mon Sep 17 00:00:00 2001
From: Colton Padden <colton@dagsterlabs.com>
Date: Wed, 27 Mar 2024 12:49:59 -0400
Subject: [PATCH] make pyright #2

---
 .../dagster_embedded_elt/dlt/resource.py                    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/python_modules/libraries/dagster-embedded-elt/dagster_embedded_elt/dlt/resource.py b/python_modules/libraries/dagster-embedded-elt/dagster_embedded_elt/dlt/resource.py
index 2873adb6a08a1..103da0f195621 100644
--- a/python_modules/libraries/dagster-embedded-elt/dagster_embedded_elt/dlt/resource.py
+++ b/python_modules/libraries/dagster-embedded-elt/dagster_embedded_elt/dlt/resource.py
@@ -1,4 +1,4 @@
-from typing import TYPE_CHECKING, Any, Iterator, Mapping, Union
+from typing import TYPE_CHECKING, Any, Iterator, Mapping, Optional, Union
 
 from dagster import (
     AssetExecutionContext,
@@ -102,8 +102,8 @@ def run(
         metadata_by_key = context.assets_def.metadata_by_key
         first_asset_metadata = next(iter(metadata_by_key.values()))
 
-        dlt_source: DltSource | None = first_asset_metadata.get(META_KEY_SOURCE)
-        dlt_pipeline: Pipeline | None = first_asset_metadata.get(META_KEY_PIPELINE)
+        dlt_source: Optional[DltSource] = first_asset_metadata.get(META_KEY_SOURCE)
+        dlt_pipeline: Optional[Pipeline] = first_asset_metadata.get(META_KEY_PIPELINE)
 
         if not dlt_source or not dlt_pipeline:
             raise Exception(