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

Compare commits

base: rik:2b4e34ec2ff6c4e8f5b2ad6ce1f185ac0ef61b60
Branches Tags
rik:main
..
compare: rik:a12c61efb49da309854e53005fdaa26c29664c1e
Branches Tags
rik:main

4 Commits
2b4e34ec2f ... a12c61efb4

Author SHA1 Message Date
Rik Veenboer
a12c61efb4 Merge remote-tracking branch 'shuttle/main' 2025-08-06 21:33:20 +02:00
Rik Veenboer
f7f5c9d7a7 untrack requirements files 2025-08-06 21:31:20 +02:00
Rik Veenboer
be608ffaa3 ignore logs folder 2025-08-06 21:30:01 +02:00
Rik Veenboer
38f8830521 tweaks on shuttle 2025-08-06 21:29:36 +02:00
2 changed files with 1 additions and 2 deletions
Expand all files Collapse all files

2
apps/vinyl/src/assets.py
View File

@@ -172,7 +172,7 @@ def works(context: dg.AssetExecutionContext) -> Iterator[dg.Output[pl.DataFrame]
dagster_type=patito_model_to_dagster_type(Deal), dagster_type=patito_model_to_dagster_type(Deal),
automation_condition=dg.AutomationCondition.on_missing().ignore( automation_condition=dg.AutomationCondition.on_missing().ignore(
dg.AssetSelection.assets(cleaned_deals.key) dg.AssetSelection.assets(cleaned_deals.key)
), )
) )
def new_deals( def new_deals(
context: dg.AssetExecutionContext, partitions: dict[str, pl.LazyFrame | None] context: dg.AssetExecutionContext, partitions: dict[str, pl.LazyFrame | None]

1
compose.code.yaml
View File

@@ -53,7 +53,6 @@ services:
<<: [ *dagster_env ] <<: [ *dagster_env ]
DAGSTER_CURRENT_IMAGE: dagster-code-stocks DAGSTER_CURRENT_IMAGE: dagster-code-stocks
volumes: volumes:
- /tmp/cache:/cache:rw
- /opt/dagster/apps/:/code/apps/:ro - /opt/dagster/apps/:/code/apps/:ro
- /opt/dagster/shared/:/code/shared/:ro - /opt/dagster/shared/:/code/shared/:ro
- /opt/dagster/logs/:/logs:rw - /opt/dagster/logs/:/logs:rw