Skip to content

Commit

Permalink
Merge pull request #2792 from didier-wenzek/feat/trigger-a-workflow-f…
Browse files Browse the repository at this point in the history
…rom-a-workflow

feat: Invoking a sub-command from an operation workflow
  • Loading branch information
didier-wenzek authored Apr 25, 2024
2 parents 329fedd + 25ca6e6 commit d5478ce
Show file tree
Hide file tree
Showing 27 changed files with 1,293 additions and 261 deletions.
6 changes: 6 additions & 0 deletions crates/common/mqtt_channel/src/topics.rs
Original file line number Diff line number Diff line change
Expand Up @@ -199,6 +199,12 @@ impl TryInto<TopicFilter> for Vec<String> {
}
}

impl AsRef<str> for Topic {
fn as_ref(&self) -> &str {
&self.name
}
}

#[cfg(test)]
mod tests {
use super::*;
Expand Down
2 changes: 1 addition & 1 deletion crates/core/tedge_agent/src/operation_file_cache/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -146,7 +146,7 @@ impl FileCacheActor {

let (entity, Channel::Command { cmd_id, .. }) = self
.mqtt_schema
.entity_channel_of(&Topic::new(&topic).unwrap())
.entity_channel_of(&topic)
.expect("only topics targeting config update command should be inserted")
else {
return Ok(());
Expand Down
Loading

0 comments on commit d5478ce

Please sign in to comment.