Ian OLeary
08/12/2024, 1:36 PMbasic_schedule = ScheduleDefinition(
job=asset_job,
cron_schedule=spec.cron_schedule,
default_status=DefaultScheduleStatus.RUNNING
)
Here's what the schedule looks like in the tap:
ALL_TAP_STREAMS: List[MeltanoSpec] = [
MeltanoSpec(
'tap',
[
"stream_1",
"stream_2",
etc...
],
"30 9 * * *",
),
Charles Feduke
08/12/2024, 2:55 PMAndy Carter
08/12/2024, 3:10 PMAndy Carter
08/12/2024, 3:11 PMIan OLeary
08/12/2024, 3:19 PMdatawarehouse-1 | 2024-08-12 15:18:08 +0000 - dagster.daemon - INFO - Instance is configured with the following daemons: ['AssetDaemon', 'BackfillDaemon', 'SchedulerDaemon', 'SensorDaemon']
Ian OLeary
08/12/2024, 3:19 PMIan OLeary
08/12/2024, 3:19 PMIan OLeary
08/12/2024, 3:25 PMmeltano invoke dagster:dev -f $REPOSITORY_DIR/repository.py --dagit-host 0.0.0.0 -d $REPOSITORY_DIR
Ian OLeary
08/12/2024, 4:25 PMIan OLeary
08/12/2024, 4:25 PMIan OLeary
08/12/2024, 4:26 PMdefs = Definitions(
assets= (meltano_assets) + [dbt_project_assets],
resources= resources,
jobs= meltano_jobs,
schedules= meltano_schedules
)
had the schedules commented out lmaoAndy Carter
08/13/2024, 6:41 AM