-
Notifications
You must be signed in to change notification settings - Fork 8
Open
Description
I've been happily using the dlt-with-debug library, but I'm running into an issue when importing the dlt signatures without an active SparkSession. I'm trying:
import dlt_with_debug.dlt_signatures as dlt
But the __init__.py calls the v2.py file which in turn tries to get the pipeline_id from the current SparkSession. But this fails when there is no active SparkSession.
I think my usecase can be achieved with an extra check in
dlt-with-debug/dlt_with_debug/v2.py
Line 8 in db7f9b3
| pipeline_id = spark.conf.get("pipelines.id", None) |
.conf.get() on it.
@souvik-databricks curious what you think! And I'd be happy to contribute via PR
Metadata
Metadata
Assignees
Labels
No labels