13414194380

Committed 19 Feb 2025 01:52PM UTC coverage: 38.241% (-0.7%) from 38.963%

Build # 13414194380

Build Type

push

github

Committed by

dariusbakunas

Commit Message

feat: add ability to load plugins based on type

Coverage Stats

0 of 38 new or added lines in 4 files covered. (0.0%)

639 of 1671 relevant lines covered (38.24%)

1.17 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/cogrs-core/src/executor/task_executor.rs

use crate::executor::task_result::TaskResult;
use crate::executor::worker_message::WorkerMessage;
use crate::inventory::host::Host;
use crate::playbook::task::Task;
use anyhow::Result;
use log::debug;
use tokio::sync::mpsc;

pub struct TaskExecutor;

impl TaskExecutor {
    pub fn new() -> Self {
        Self {}
    }

    pub fn run(
        &self,
        host: &Host,
        task: &Task,
        sender: &mpsc::Sender<WorkerMessage>,
    ) -> Result<TaskResult> {
        debug!(
            "executor run() - task {}, host: {}",
            task.uuid(),
            host.name()
        );
        let result = TaskResult::new(host.name(), task.uuid());
        // TODO: handle with_*
        // TODO: get connection plugin

        Ok(result)
    }
}

1	use crate::executor::task_result::TaskResult;
2	use crate::executor::worker_message::WorkerMessage;
3	use crate::inventory::host::Host;
4	use crate::playbook::task::Task;
5	use anyhow::Result;
6	use log::debug;
7	use tokio::sync::mpsc;
8
9	pub struct TaskExecutor;
10
11	impl TaskExecutor {
12	pub fn new() -> Self {
13	Self {}
14	}
15
16	pub fn run(	×
17	&self,
18	host: &Host,
19	task: &Task,
20	sender: &mpsc::Sender<WorkerMessage>,
21	) -> Result<TaskResult> {
22	debug!(	×
23	"executor run() - task {}, host: {}",
24	task.uuid(),
25	host.name()
26	);
NEW 27	let result = TaskResult::new(host.name(), task.uuid());	×
28	// TODO: handle with_*
29	// TODO: get connection plugin
30
NEW 31	Ok(result)	×
32	}
33	}

dariusbakunas / cogrs / 13414194380

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous