Zum Inhalt

Jobs

IJob repräsentiert eine ausführbare Einheit innerhalb eines Graphen.

Erstellen Sie Jobs über 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");

Abhängigkeiten werden explizit über After(...) oder die fluente Then(...)-Extension ausgedrückt:

extract.Then(transform);

Öffentliche Contract-Quelle

IJob selbst gehört zum öffentlichen Repository TplQueue.Abstractions:

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

Öffentliche Source-Links: