在Prefect流中使用prefect-databricks时无法正常打印内容的问题求助
在Prefect流中使用prefect-databricks时无法正常打印内容的问题求助
我刚接触用Prefect做工作流编排,最近在探索它和Databricks的集成,跟着官方的教程示例操作。目前我已经能成功连接到Databricks实例,而且在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)
它并没有打印出预期的任务列表,反而返回了一个协程对象。我试过用async/await语法,也试过在任务里返回结果然后在流中打印,但都没有效果。有没有大佬能给我一些建议或者解决方案呀?
备注:内容来源于stack exchange,提问作者vaibhav
相关产品推荐
相关产品推荐

