We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 465ecb0 commit f4b3d7eCopy full SHA for f4b3d7e
src/builder/flow_builder.rs
@@ -259,13 +259,16 @@ impl FlowBuilder {
259
pub fn new(name: &str) -> PyResult<Self> {
260
let lib_context = get_lib_context().into_py_result()?;
261
let existing_flow_ss = lib_context
262
- .require_all_setup_states()
263
- .into_py_result()?
264
- .read()
265
- .unwrap()
266
- .flows
267
- .get(name)
268
- .cloned();
+ .persistence_ctx
+ .as_ref()
+ .and_then(|ctx| {
+ ctx.all_setup_states
+ .read()
+ .unwrap()
+ .flows
269
+ .get(name)
270
+ .cloned()
271
+ });
272
let root_op_scope = OpScope::new(
273
spec::ROOT_SCOPE_NAME.to_string(),
274
None,
0 commit comments