Francis Addae
03/31/2022, 4:55 PMowen
03/31/2022, 4:59 PMScheduleDefinition(job=my_job, cron_schedule="0 0 * * *")
to your repository. Our docs have a bunch more examples for other scenarios as well: https://docs.dagster.io/concepts/partitions-schedules-sensors/schedules#a-basic-scheduleFrancis Addae
03/31/2022, 5:01 PMowen
03/31/2022, 5:02 PMFrancis Addae
03/31/2022, 5:03 PM#Call the files
@job(resource_defs= {'dbt': dbt_run})
def main():
e = dagETL.extract_data()
t = dagETL.transform(e)
l = dagETL.loading(t)
d = dbt_run_op(l)
if __name__ == "__main__":
result = main.execute_in_process()
<http://logger.info|logger.info>(result)
owen
03/31/2022, 5:07 PMFrancis Addae
04/01/2022, 2:17 PMowen
04/01/2022, 5:58 PMdagster --help
, you should also be able to run dagster-daemon --help
. if those don't work, let me know what error you're running into