rik/dagster
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

linting

Browse Source
This commit is contained in:
Rik Veenboer
2025-07-29 11:27:22 +02:00
parent 304e1f1594
commit 80c0452cde
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
apps/vinyl/src/definitions.py
View File

@@ -28,6 +28,8 @@ def deep_merge_dicts(base: dict, override: dict) -> dict:
return result
storage_dir = os.environ.get("STORAGE_DIR", "/storage")
definitions = dg.Definitions(
assets=[
asset.with_attributes(
@@ -37,9 +39,7 @@ definitions = dg.Definitions(
for asset in dg.load_assets_from_modules([assets])
],
resources={
"polars_parquet_io_manager": PolarsParquetIOManager(
base_dir=os.environ.get("STORAGE_DIR", "/storage")
),
"polars_parquet_io_manager": PolarsParquetIOManager(base_dir=storage_dir),
"email_service": EmailService(
smtp_server=dg.EnvVar("SMTP_SERVER"),
smtp_port=dg.EnvVar.int("SMTP_PORT"),