Compare commits
5 Commits
a12c61efb4
...
2b4e34ec2f
| Author | SHA1 | Date | |
|---|---|---|---|
| 2b4e34ec2f | |||
| eaf469d68f | |||
| 3c7f46fb4f | |||
| 866e190ed0 | |||
| 968d5c34de |
@@ -172,7 +172,7 @@ def works(context: dg.AssetExecutionContext) -> Iterator[dg.Output[pl.DataFrame]
|
||||
dagster_type=patito_model_to_dagster_type(Deal),
|
||||
automation_condition=dg.AutomationCondition.on_missing().ignore(
|
||||
dg.AssetSelection.assets(cleaned_deals.key)
|
||||
)
|
||||
),
|
||||
)
|
||||
def new_deals(
|
||||
context: dg.AssetExecutionContext, partitions: dict[str, pl.LazyFrame | None]
|
||||
|
||||
@@ -53,6 +53,7 @@ services:
|
||||
<<: [ *dagster_env ]
|
||||
DAGSTER_CURRENT_IMAGE: dagster-code-stocks
|
||||
volumes:
|
||||
- /tmp/cache:/cache:rw
|
||||
- /opt/dagster/apps/:/code/apps/:ro
|
||||
- /opt/dagster/shared/:/code/shared/:ro
|
||||
- /opt/dagster/logs/:/logs:rw
|
||||
|
||||
Reference in New Issue
Block a user