dao_treasury.streams package

Submodules

dao_treasury.streams.llamapay module

final class dao_treasury.streams.llamapay.LlamaPayProcessor

Bases: object

Generalized async processor for DAO stream contracts. Args are passed in at construction time. Supports time-bounded admin periods for filtering.

__init__()

Return type:

None

async process_stream(stream_id, run_forever=False)

Parameters:

• stream_id (HexStr)

• run_forever (bool)

Return type:

None

async process_stream_for_date(stream_id, date_obj)

Parameters:

• stream_id (HexStr)

• date_obj (datetime)

Return type:

StreamedFunds | None

async process_streams(run_forever=False)

Parameters:

run_forever (bool)

Return type:

None

streams_for_recipient(recipient, at_block=None)

Parameters:

• recipient (ChecksumAddress)

• at_block (BlockNumber | None)

Return type:

List[Stream]

streams_for_token(token, include_inactive=False)

Parameters:

• token (ChecksumAddress)

• include_inactive (bool)

Return type:

List[Stream]

handled_events: Final = ('StreamCreated', 'StreamCreatedWithReason', 'StreamModified', 'StreamPaused', 'StreamCancelled')

skipped_events: Final = ('PayerDeposit', 'PayerWithdraw', 'Withdraw')

dao_treasury.streams.llamapay.fromtimestamp()

timestamp[, tz] -> tz’s local time from POSIX timestamp.

dao_treasury.streams.llamapay.now(tz=None)

Returns new datetime object representing current time local to tz.

tz

Timezone object.

If no tz is specified, uses local timezone.

Module contents