diff --git a/dlt_with_debug/v2.py b/dlt_with_debug/v2.py
index de6117f..fbaa93a 100644
--- a/dlt_with_debug/v2.py
+++ b/dlt_with_debug/v2.py
@@ -5,7 +5,7 @@
 from pyspark.sql import SparkSession
 
 spark = SparkSession.getActiveSession()
-pipeline_id = spark.conf.get("pipelines.id", None)
+pipeline_id = spark.conf.get("pipelines.id", None) if spark else None
 
 
 def dltwithdebug(g_ns):