Skip to content

Module yapapi.runner.events

Representing and logging events in Golem computation.

Variables

E

ResourceId

Functions

log_event

def log_event(
    event_type:yapapi.runner.events.EventType,
    resource_id:Union[int, str, NoneType]=None,
    **kwargs:Any
) -> None

Log an event.

Classes

AsyncEventBuffer

class AsyncEventBuffer(
    wrapped_emitter:yapapi.runner.events.EventEmitter
)

Wraps a given event emitter to provide buffering.

The emitter method is an event emitter that buffers the events and emits them asynchronously later using the wrapped emitter.

Ancestors (in MRO)

  • typing.AsyncContextManager
  • typing.Generic

Methods

emitter
def emitter(
    self,
    event_type:yapapi.runner.events.EventType,
    resource_id:Union[int, str, NoneType]=None,
    **kwargs:Any
) -> None

Buffer the event to be emitted asynchronously by the wrapped emitter.

ET

class ET(
    /,
    *args,
    **kwargs
)

Types of computation events.

Ancestors (in MRO)

  • enum.Enum

Class variables

ACTIVITY_CREATED

ACTIVITY_CREATE_FAILED

AGREEMENT_CONFIRMED

AGREEMENT_CREATED

AGREEMENT_REJECTED

BATCH_DONE

BATCH_GET_RESULTS

BATCH_SENT

BATCH_STEP

DOWNLOAD_FINISHED

DOWNLOAD_STARTED

PAYMENT_ACCEPTED

PAYMENT_PREPARED

PAYMENT_QUEUED

PROPOSAL_BUFFERED

PROPOSAL_FAILED

PROPOSAL_RECEIVED

PROPOSAL_REJECTED

PROPOSAL_RESPONDED

SUBSCRIPTION_COLLECT_FAILED

SUBSCRIPTION_CREATED

SUBSCRIPTION_FAILED

TASK_ACCEPTED

TASK_REJECTED

WORKER_CREATED

WORKER_DONE

WORKER_GET_WORK

name

value

EventEmitter

class EventEmitter(
    *args,
    **kwargs
)

A protocol for callables that can emit events of type E.

Ancestors (in MRO)

  • typing_extensions.Protocol

Descendants

  • yapapi.runner.events.EventEmitter
  • yapapi.runner.events.EventEmitter
  • yapapi.runner.events.EventEmitter

EventType

class EventType(
    /,
    *args,
    **kwargs
)

Types of computation events.

Ancestors (in MRO)

  • enum.Enum

Class variables

ACTIVITY_CREATED

ACTIVITY_CREATE_FAILED

AGREEMENT_CONFIRMED

AGREEMENT_CREATED

AGREEMENT_REJECTED

BATCH_DONE

BATCH_GET_RESULTS

BATCH_SENT

BATCH_STEP

DOWNLOAD_FINISHED

DOWNLOAD_STARTED

PAYMENT_ACCEPTED

PAYMENT_PREPARED

PAYMENT_QUEUED

PROPOSAL_BUFFERED

PROPOSAL_FAILED

PROPOSAL_RECEIVED

PROPOSAL_REJECTED

PROPOSAL_RESPONDED

SUBSCRIPTION_COLLECT_FAILED

SUBSCRIPTION_CREATED

SUBSCRIPTION_FAILED

TASK_ACCEPTED

TASK_REJECTED

WORKER_CREATED

WORKER_DONE

WORKER_GET_WORK

name

value