Jobs

IJob represents one executable unit inside a graph.

Create jobs through IJobFactory:

ICoreApi core = CoreApi.Create();

IJob extract = core.JobFactory.Job(
    async ct => await Task.CompletedTask,
    name: "Extract");

IJob transform = core.JobFactory.Job(
    async ct => await Task.CompletedTask,
    name: "Transform");

Dependencies are expressed explicitly through After(...) or the fluent Then(...) extension:

extract.Then(transform);

Public contract source

IJob itself is owned by the public TplQueue.Abstractions repository:

public interface IJob : IJobNode
{
    IJob After(params IJob[] previousTasks);
}

Public source links:

• IJob
• IJobFactory