marcos
12/02/2022, 3:09 PMdefine_asset_job
and there is a good chance I am including tags in there that don’t do what I think they should.
assets_schedule = build_schedule_from_partitioned_job(
define_asset_job(
"xxxxxx_job",
selection=AssetSelection.groups("xxxxxx"),
tags={
"dagster-k8s/config": {
"container_config": {
"resources": {
"requests": {"cpu": "500m", "memory": "1Gi"},
}
},
},
"dagster/max_retries": 2,
"dagster/retry_strategy": "ALL_STEPS"
},
partitions_def=daily_partitions,
),
hour_of_day=3,
)
daniel
12/02/2022, 3:22 PMmarcos
12/02/2022, 4:19 PM