Logs.
This commit is contained in:
@@ -561,7 +561,7 @@ async fn publish_outputs(
|
|||||||
route_map: &HashMap<String, Vec<String>>,
|
route_map: &HashMap<String, Vec<String>>,
|
||||||
) -> Result<(), AnyError> {
|
) -> Result<(), AnyError> {
|
||||||
for (result_id, case_var) in outputs {
|
for (result_id, case_var) in outputs {
|
||||||
info("Shuttle output result_id={}, case_var={}", result_id, case_var);
|
info!("Shuttle output result_id={}, case_var={}", result_id, case_var);
|
||||||
if let Some(outbound_queues) = route_map.get(&case_key(&case_var)) {
|
if let Some(outbound_queues) = route_map.get(&case_key(&case_var)) {
|
||||||
for queue in outbound_queues {
|
for queue in outbound_queues {
|
||||||
let payload = result_id.to_string();
|
let payload = result_id.to_string();
|
||||||
|
|||||||
Reference in New Issue
Block a user