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: any
Defined in
•
Private
_activity_api: any
Defined in
•
Private
_api_config: any
Defined in
Defined in
•
Private
_budget_amount: any
Defined in
Defined in
•
Private
_chan_computation_done: any
Defined in
•
Private
_conf: any
Defined in
•
Private
_driver: any
Defined in
•
Private
_expires: any
Defined in
•
Private
_market_api: any
Defined in
•
Private
_network: any
Defined in
•
Private
_payment_api: any
Defined in
•
Private
_stack: any
Defined in
•
Private
_strategy: any
Defined in
•
Private
_stream_output: any
Defined in
•
Private
_subnet: any
Defined in
•
Private
_task_package: any
Defined in
•
Private
_wrapped_consumer: any
Defined in
Defined in
▸ _create_allocations():
Promise
Returns
Promise
Defined 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():
Promise
Returns
Promise
Defined in
▸ find_offers(
state
, emit
): Promise
Parameters
Name | Type |
---|---|
state | |
emit |
Returns
Promise
Defined in
▸ find_offers_for_subscription(
state
, subscription
, emit
): Promise
Parameters
Name | Type |
---|---|
state | |
subscription | |
emit |
Returns
Promise
Defined 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