Как я могу напечатать что-то внутри потока префектов, который использует префектные блоки данных? ⇐ Python

[Anonymous]

Я новичок в области оркестрации рабочих процессов. Я изучал интеграцию блоков данных и использовал здесь учебный пример. Я могу подключиться к экземпляру datarbricks и распечатать задания вне потока, то есть в main, примерно так:

Код: Выделить всё

if __name__ == "__main__":
jobs = example_execute_endpoint_flow()
print(jobs)

но если я попытаюсь напечатать это внутри самого потока

Код: Выделить всё

@task
def get_job_list():
databricks_credentials = DatabricksCredentials.load("tnaiv-databricks")
jobs = jobs_list(
databricks_credentials,
limit=5
)
print(jobs)

он ​​не печатает, он отправляет сопрограмму. Я пробовал асинхронное ожидание, я также пробовал сделать это внутри задачи, вернуть оттуда задания и распечатать их в потоке. Ничего не работает. Любые предложения или решения!

Подробнее здесь: https://stackoverflow.com/questions/793 ... databricks