Class FlowGraphOrchestrator

Orchestrates a job containing a FlowGraph work unit

Inheritance
System.Object
JobOrchestratorBase
FlowGraphOrchestrator
Inherited Members
Namespace: DNVGL.One.Compute.Scheduling.Scheduler
Assembly: DNVGL.One.Compute.Scheduling.dll
Syntax
public class FlowGraphOrchestrator : JobOrchestratorBase, IJobOrchestrator, IJobEventPublisher

Constructors

View Source

FlowGraphOrchestrator(IJobEventPublisher, ILogger, IWorkScheduler, IWorkItemStatusService, IJobStatusService, IFlowModelStorageService<WorkItem>)

Initializes a new instance of the FlowGraphOrchestrator class.

Declaration
public FlowGraphOrchestrator(IJobEventPublisher eventPublisher, ILogger logger, IWorkScheduler scheduler, IWorkItemStatusService taskStatusService, IJobStatusService jobStatusService, IFlowModelStorageService<WorkItem> workItemStorageService)
Parameters
Type Name Description
IJobEventPublisher eventPublisher

The job event publisher.
ILogger logger

The logger.
IWorkScheduler scheduler

The scheduler.
IWorkItemStatusService taskStatusService

The task status service.
IJobStatusService jobStatusService

The job status service.
IFlowModelStorageService<WorkItem> workItemStorageService

The work item storage service.

Methods

View Source

Work(Job)

Orchestrate the job.

Declaration
public override void Work(Job job)
Parameters
Type Name Description
Job job

The job.
Overrides

Explicit Interface Implementations

View Source

IJobEventPublisher.PostJobProgressChangedAsync(String, Double, String)

Posts a job progress changed event.

Declaration
Task IJobEventPublisher.PostJobProgressChangedAsync(string jobId, double progress, string message)
Parameters
Type Name Description
System.String jobId

The job identifier.
System.Double progress

The progress.
System.String message

The message.
Returns
Type Description
Task

Asynchronous task
View Source

IJobEventPublisher.PostJobStatusChangedAsync(String, WorkStatus, String)

Posts a job status changed event.

Declaration
Task IJobEventPublisher.PostJobStatusChangedAsync(string jobId, WorkStatus jobStatus, string message)
Parameters
Type Name Description
System.String jobId

The job identifier.
WorkStatus jobStatus

The job status.
System.String message

The message.
Returns
Type Description
Task

Asynchronous task
View Source

IJobEventPublisher.PostWorkItemProgressChangedAsync(String, String, Double, String)

Posts a work item progress changed event.

Declaration
Task IJobEventPublisher.PostWorkItemProgressChangedAsync(string jobId, string workItemId, double progress, string message)
Parameters
Type Name Description
System.String jobId

The job identifier.
System.String workItemId

The work item identifier.
System.Double progress

The progress.
System.String message

The message.
Returns
Type Description
Task

Asynchronous task
View Source

IJobEventPublisher.PostWorkItemStatusChangedAsync(String, String, WorkStatus, String)

Posts a work item status changed event.

Declaration
Task IJobEventPublisher.PostWorkItemStatusChangedAsync(string jobId, string workItemId, WorkStatus workItemStatus, string message)
Parameters
Type Name Description
System.String jobId

The job identifier.
System.String workItemId

The work item identifier.
WorkStatus workItemStatus

The work item status.
System.String message

The message.
Returns
Type Description
Task

Asynchronous task

Implements

See Also