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 c2ceddc commit 5a88acfCopy full SHA for 5a88acf
1 file changed
crates/base/src/store.rs
@@ -131,9 +131,15 @@ impl AdapterStore {
131
}
132
133
let uuid = uuid::Uuid::new_v4().to_string();
134
+ let flow_id = flow.flow_id;
135
let execution_flow: ExecutionFlow = Self::convert_validation_flow(flow, input_value);
136
let bytes = execution_flow.encode_to_vec();
137
let topic = format!("execution.{}", uuid);
138
+ log::info!(
139
+ "Requesting the exectition of the flow: {} with an execution id {}",
140
+ flow_id,
141
+ uuid
142
+ );
143
let result = self.client.request(topic, bytes.into()).await;
144
145
match result {
0 commit comments