BaseUpdateProcessor

class telegram.ext.BaseUpdateProcessor(max_concurrent_updates)

Bases: ABC

An abstract base class for update processors. You can use this class to implement your own update processor.

Use In

telegram.ext.ApplicationBuilder.concurrent_updates()

Available In

telegram.ext.Application.update_processor

See also

Concurrency

New in version 20.4.

Parameters:

max_concurrent_updates (int) – The maximum number of updates to be processed concurrently. If this number is exceeded, new updates will be queued until the number of currently processed updates decreases.

Raises:

ValueError – If max_concurrent_updates is a non-positive integer.

abstract async do_process_update(update, coroutine)

Custom implementation of how to process an update. Must be implemented by a subclass.

Warning

This method will be called by process_update(). It should not be called manually.

Parameters:

• update (object) – The update to be processed.

• coroutine (Awaitable) – The coroutine that will be awaited to process the update.

abstract async initialize()

Initializes the processor so resources can be allocated. Must be implemented by a subclass.

See also

shutdown()

property max_concurrent_updates

The maximum number of updates that can be processed concurrently.

Type:

int

final async process_update(update, coroutine)

Calls do_process_update() with a semaphore to limit the number of concurrent updates.

Parameters:

• update (object) – The update to be processed.

• coroutine (Awaitable) – The coroutine that will be awaited to process the update.

abstract async shutdown()

Shutdown the processor so resources can be freed. Must be implemented by a subclass.

See also

initialize()