在Google PubSub中,每个源都有一个单独的主题;当更新一个源时,它在相应的主题订阅中发送一条消息。当所有源被更新时(即当每个订阅中至少有一条新消息时),作业就可以启动。这项工作是按气流安排的。DAG从一系列并行任务开始,每个订阅都检查是否发布了新消息,但没有对其进行分类。下一个任务等待所有前面的任务,并使用XCOM查看 all 是否包含一条消息。在这种情况下,它将继续执行作业(它首先对消息进行分类),否则它
{“属性”:{ "contentFormat":"swagger-link-json","contentValue":"","path":"demoapi2",}}(“免费”产品是不需要订阅的产品) GET works perfect
然后我尝试进行新的修订(以反映更新后的swaggerfile)属性{“”:{ "contentFormat":“swagger--json”,"contentVal