Class: Executor
Task executor
description Used to run tasks using the specified application package within providers' execution units.• new Executor(
__namedParameters)Create new executor
Parameters
Name | Type |
|---|---|
__namedParameters |
Defined in
•
Private _active_computations: anyDefined in
•
Private _activity_api: anyDefined in
•
Private _api_config: anyDefined in
Defined in
•
Private _budget_amount: anyDefined in
Defined in
•
Private _chan_computation_done: anyDefined in
•
Private _conf: anyDefined in
•
Private _driver: anyDefined in
•
Private _expires: anyDefined in
•
Private _market_api: anyDefined in
•
Private _network: anyDefined in
•
Private _payment_api: anyDefined in
•
Private _stack: anyDefined in
•
Private _strategy: anyDefined in
•
Private _stream_output: anyDefined in
•
Private _subnet: anyDefined in
•
Private _task_package: anyDefined in
•
Private _wrapped_consumer: anyDefined in
Defined in
▸ _create_allocations():
PromiseReturns
PromiseDefined in
Parameters
Returns
Defined in
▸ _get_common_payment_platforms(
proposal): string[]Parameters
Name | Type |
|---|---|
proposal |
Returns
string[]Defined in
Parameters
Name | Type |
|---|---|
state | |
proposal |
Returns
Defined in
Parameters
Name | Type |
|---|---|
worker | |
data |
Returns
Defined in
▸ done():
PromiseReturns
PromiseDefined in
▸ find_offers(
state, emit): PromiseParameters
Name | Type |
|---|---|
state | |
emit |
Returns
PromiseDefined in
▸ find_offers_for_subscription(
state, subscription, emit): PromiseParameters
Name | Type |
|---|---|
state | |
subscription | |
emit |
Returns
PromiseDefined in
Returns
Defined in
Submit a computation to be executed on providers.
Parameters
Name | Type | Description |
|---|---|---|
worker | a callable that takes a WorkContext object and a list o tasks, adds commands to the context object and yields committed commands | |
data | an iterator of Task objects to be computed on providers |
Returns
yields computation progress events
Defined in
Last modified 1yr ago