Class: TaskExecutor

executor.TaskExecutor

A high-level module for defining and executing tasks in the golem network

• constructor

• events

• create
• init
• shutdown
• getStats
• onActivityReady
• run
• cancel

• new TaskExecutor(options)

Create a new TaskExecutor object.

src/executor.ts:195

• Readonly events: EventEmitter<TaskExecutorEventsDict, any>

EventEmitter (EventEmitter3) instance emitting TaskExecutor events.

See

TaskExecutorEventsDict for available events.

src/executor.ts:120

▸ Static create(options): Promise<TaskExecutor>

Create a new Task Executor

Promise<TaskExecutor>

TaskExecutor

Description

Factory Method that create and initialize an instance of the TaskExecutor

Example

Simple usage of Task Executor

The executor can be created by passing appropriate initial parameters such as package, budget, subnet tag, payment driver, payment network etc. One required parameter is a package. This can be done in two ways. First by passing only package image hash or image tag, e.g.

const executor = await TaskExecutor.create("9a3b5d67b0b27746283cb5f287c13eab1beaa12d92a9f536b747c7ae");

or

const executor = await TaskExecutor.create("golem/alpine:3.18.2");

Example

Usage of Task Executor with custom parameters

Or by passing some optional parameters, e.g.

const executor = await TaskExecutor.create({
  subnetTag: "public",
  payment: { driver: "erc-20", network: "holesky" },
  package: "golem/alpine:3.18.2",
});

src/executor.ts:184

▸ init(): Promise<void>

Initialize executor

Promise<void>

Description

Method responsible initialize all executor services.

src/executor.ts:254

▸ shutdown(): Promise<void>

Stop all executor services and shut down executor instance.

You can call this method multiple times, it will resolve only once the executor is shutdown.

When shutdown() is initially called, a beforeEnd event is emitted.

Once the executor is fully stopped, an end event is emitted.

Promise<void>

src/executor.ts:324

▸ getStats(): Object

Object

src/executor.ts:356

▸ onActivityReady(worker): void

Registers a worker function that will be run when an activity is ready. This is the perfect place to run setup functions that need to be run only once per activity, for example uploading files that will be used by all tasks in the activity. This function can be called multiple times, each worker will be run in the order they were registered.

void

Example

const uploadFile1 = async (ctx) => ctx.uploadFile("./file1.txt", "/file1.txt");
const uploadFile2 = async (ctx) => ctx.uploadFile("./file2.txt", "/file2.txt");

executor.onActivityReady(uploadFile1);
executor.onActivityReady(uploadFile2);

await executor.run(async (ctx) => {
 await ctx.run("cat /file1.txt /file2.txt");
});

src/executor.ts:384

▸ run<OutputType>(worker, options?): Promise<OutputType>

Run task - allows to execute a single worker function on the Golem network with a single provider.

Promise<OutputType>

result of task computation

Example

await executor.run(async (ctx) => console.log((await ctx.run("echo 'Hello World'")).stdout));

src/executor.ts:399

▸ cancel(reason): Promise<void>

Promise<void>

src/executor.ts:447