Skip to content

Commit

Permalink
Fix clippy issues
Browse files Browse the repository at this point in the history
  • Loading branch information
thomaskrause committed Aug 2, 2024
1 parent cf17bc1 commit 42e3bd2
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 15 deletions.
2 changes: 1 addition & 1 deletion src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -474,7 +474,7 @@ impl ManipulatorStep {
self.module.processor().manipulate_corpus(
graph,
workflow_directory,
StepID::from_graphop_step(&self, position_in_workflow),
StepID::from_graphop_step(self, position_in_workflow),
tx,
)
}
Expand Down
20 changes: 6 additions & 14 deletions src/workflow.rs
Original file line number Diff line number Diff line change
Expand Up @@ -145,26 +145,18 @@ impl Workflow {

if let Some(tx) = &tx {
let mut steps: Vec<StepID> = Vec::default();
steps.extend(
self.import
.iter()
.map(|importer| StepID::from_importer_step(&importer)),
);
steps.extend(self.import.iter().map(StepID::from_importer_step));
steps.push(apply_update_step_id.clone());

let mut graph_op_position = 1;
if let Some(ref manipulators) = self.graph_op {
for m in manipulators {
steps.push(StepID::from_graphop_step(&m, graph_op_position));
steps.push(StepID::from_graphop_step(m, graph_op_position));
graph_op_position += 1;
}
}
if let Some(ref exporters) = self.export {
steps.extend(
exporters
.iter()
.map(|exporter| StepID::from_exporter_step(&exporter)),
);
steps.extend(exporters.iter().map(StepID::from_exporter_step));
}
tx.send(StatusMessage::StepsCreated(steps))?;
}
Expand Down Expand Up @@ -218,7 +210,7 @@ impl Workflow {
if let Some(ref manipulators) = self.graph_op {
let mut graph_op_position = 1;
for desc in manipulators.iter() {
let step_id = StepID::from_graphop_step(&desc, graph_op_position);
let step_id = StepID::from_graphop_step(desc, graph_op_position);
let workflow_directory = &desc.workflow_directory;
desc.execute(
&mut g,
Expand Down Expand Up @@ -271,7 +263,7 @@ impl Workflow {
default_workflow_directory: &Path,
tx: Option<StatusSender>,
) -> Result<GraphUpdate> {
let step_id = StepID::from_importer_step(&step);
let step_id = StepID::from_importer_step(step);

// Do not use the import path directly, but resolve it against the
// workflow directory if the path is relative.
Expand Down Expand Up @@ -308,7 +300,7 @@ impl Workflow {
default_workflow_directory: &Path,
tx: Option<StatusSender>,
) -> Result<()> {
let step_id = StepID::from_exporter_step(&step);
let step_id = StepID::from_exporter_step(step);

// Do not use the output path directly, but resolve it against the
// workflow directory if the path is relative.
Expand Down

0 comments on commit 42e3bd2

Please sign in to comment.