You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

在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

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.04.14 16:53:12