triggered_jobs.py
из задания на импорт дагстера
Код: Выделить всё
@job
def MY_JOB():
print("+-+-+-+-+-+-+-/-/-/-=/-=/-=-_?+?+")
print("+-+-+-+-+-+-+-/-/-/-=/-=/-=-_?+?+")
print("+-+-+-+-+-+-+-/-/-/-=/-=/-=-_?+?+")
print("+-+-+-+-+-+-+-/-/-/-=/-=/-=-_?+?+")
print("+-+-+-+-+-+-+-/-/-/-=/-=/-=-_?+?+")
print("+-+-+-+-+-+-+-/-/-/-=/-=/-=-_?+?+")
print("+-+-+-+-+-+-+-/-/-/-=/-=/-=-_?+?+")
Код: Выделить всё
defs = Definitions(
assets=(
assets1 +
assets2 +
[]
),
jobs=[
job1,
job2,
MY_JOB,
],
...
Я пытался запустить только dagster-daemon (
Код: Выделить всё
dagster-daemon runПодробнее здесь: https://stackoverflow.com/questions/791 ... on-its-own
Мобильная версия