我希望能够重用相同的参数化流，但因输入而异。举个例子：from prefect.schedules import CronSchedule
with Flow(name="wakuptime") as this_fl
浏览 8提问于2019-12-04得票数 3
1回答
在prefect中，我希望按计划运行带有参数的流。这听起来很自然地传递参数，例如db凭据，对吗？我已经创建了一个具有与prefect run -p flow.py --param db_config_path=somepath一样运行良好的参数的流，现在我希望将它注册为prefect register", line 285, in create_flow\n awa
浏览 13提问于2022-04-14得票数 0
1回答
嗨，我试图应用到我的项目中，使用库click处理命令行的段落。if __name__ == "__main__": another_method()flow = Flow("hello-flow", tasks=[hello_task])但是，如果我需要运行这个程序，比如说po
浏览 3提问于2021-12-13得票数 0
回答已采纳
1回答
我目前在一个简单的python类中定义了一个工作流。在这个类中，我为每个任务定义了一个单独的方法。我现在通过class.run()启动ETL。 ..._proess_data(data)
我现在有不同的数据，应该由ETL处理。因此，我从Main类继承了一个新类，并覆盖了read_data方法。这样，我有一个干净的代码结构，并希望将方法转移到Prefect。我还可以定义一个流类来替换不同数据的read_data方法吗？有谁给我举过一个可理
浏览 7提问于2022-03-14得票数 0
1回答
问题是调用是可迭代的，对于大型容器，无法将所有条目保存在内存中。我相信我的问题可以归结为：
yield from range(1000000) # some large amount of work
def some_pr
浏览 1提问于2021-03-16得票数 0
我有下面的 urls = Parameter("urls", default=['url1', 'url2']) result = get_url(urls)TypeError: 'Parameter' object
浏览 2提问于2020-10-01得票数 2
回答已采纳
在完美的工作流程中，我尝试持久化每次计划运行的数据。我需要比较每个先前和当前结果的数据。我尝试了Localresult和checkpoint=true，但它不起作用。例如,from prefect.engine.results import LocalResult
from prefect.schedules", checkpoint=True, result=LocalResult(dir=&q
浏览 5提问于2021-03-17得票数 1
我正在探索Prefect的map-还原功能，它是一个强大的成语，用于编写大规模并行、健壮的外部数据导入程序。(episode_ids)与简单的X文件教程相比，我的流程的特点是，我希望对我所要求的所有片段，即使是失败的部分，保持结果。想象一下，我将以带有is_success标志的插集ID的形式将剧集写入
浏览 2提问于2022-04-28得票数 0
我已经开始在各种项目中使用Prefect，现在我需要决定在GCP上使用哪种部署策略最好。最好是我喜欢无服务器工作。，我倾向于选择后者，因为它没有超时限制，而其他两个分别有9个。15分钟或者，一种更经典的方法是在上部署Prefect。但我觉得这有点过时了，没有公平地对待Prefect的功能和未来开发的灵活性。
浏览 1提问于2020-04-24得票数 11
考虑一个prefect任务，它的内存需求事先不知道。如果任务由于工作人员没有足够的内存而失败，是否可以修改dask工作者参数并重新运行该任务？如果有一种方法可以在每次失败后将每个工作人员的内存分配增加一些值，那就太好了。
浏览 6提问于2021-12-11得票数 0
回答已采纳
我正在尝试找到一种方法来更新begin用于计划流程的每次迭代的参数。 例如，假设我有一个流，该流计划在一年内每个星期一运行一次。对于第一个星期一，流需要使用参数5运行。下个星期一需要使用参数7运行，依此类推。每周运行所需的参数将按常量变化。 根据文档，看起来我可以为每次运行创建一个带有相应参数的时钟，但对于计划多次运行的流来说，这似乎过多了。在Prefect中有没
浏览 22提问于2020-11-06得票数 1
回答已采纳
1回答
, pub data: Option<&'a i32>, fn flow(&'a self, dest: &mut Dest<'b>);
impl<'a: 'b, 'b> Flowable<'a, 'b> for Src&l
浏览 0提问于2018-12-14得票数 2
回答已采纳
我正在尝试创建一个Prefect任务，它接收PyMySQL connection的一个实例作为输入，例如：def connect_db():
def save_csv(df): df.to_csv(path, sep=';', index=False)
con = co
浏览 14提问于2021-06-12得票数 1
有一个简单的表单，它使用一个参数进入流： Click to enter flow1<h:form>
Hi this is page 1.我想在进入流时实现post-redirect-get，以便浏览器地址栏与视图保持同步。
浏览 9提问于2014-05-20得票数 10
作为依赖图，节点是产生输出或执行某些其他工作的任务。这在工作流工具中似乎相当普遍。 然而，我需要的关键是每个任务都是由它所需的参数定义的。根据这些参数及其依赖项的所有参数的状态实例化任务。因此，如果一个任务已经根据给定的参数状态完成了它的作业，那么它就是完成的，并且不会重新运行。此参数状态不是全局参数状态，而只
浏览 22提问于2020-03-31得票数 2
1回答
好的，我在找一种方法来比较两个音频样本当它在房间的两个不同的地方播放时，从一个固定点听到。。编程完全不是我的领域，但作为一名音响工程师，我对此非常感兴趣。
提前感谢你的想法。抢夺
浏览 1提问于2011-03-23得票数 0
1回答
我一直试图使用@pytest.mark.parametrize参数化我的测试，并且我有一个营销人员@pytest.mark.test("1234")，我使用来自测试标记的值来将结果发布到JIRA。注意每个test_data的标记更改所给的值。本质上，代码如下所示。expected"),[ (2, 3)]) assert n + 1 =
浏览 0提问于2020-08-24得票数 4
回答已采纳
3回答
我有一个查询，我需要让ordeby基于查询字符串参数.For例如，如果sortby参数是价格，查询需要随价格变化。如果其评级大于将查询更改为按评级排序。我知道PredicateBuilder可以做And和OR之类的事情，但是我怎么做一个动态的ordeby linq查询呢？
浏览 0提问于2011-10-22得票数 9
回答已采纳
当我们有一个有很多字段的类，其中一些是强制的，一些是可选的，那么使用构造函数是一种糟糕的做法，因为有几个问题，其中一个是可读性差。我的问题是：
1.)为什么我们不能将Setter与参数化构造函数相结合，该构造函数将包含必填字段而不是Builder模式？可以使用setter设置可选字段。2.)为什么我们应该使用构建器设计模式，而不是带有参数化构造函数的Setter？
浏览 3提问于2021-06-12得票数 1
1回答
下面是我死去的简单流程：import datetime
def firstflow(inreq): retval我的问题是怎样用卷发来做触发？注意:我已经读过了。但我那蹩脚的大脑却找不到该怎么做。注意：
7ca8a456-94d7-4aa1-80b9-64894fdca93bParameters 让我们说我的流id是:我想要被处理的是{'msg&
浏览 5提问于2022-08-16得票数 3
云服务器
ICP备案
对象存储
云直播
实时音视频
腾讯云开发者
