TAPBusiness

class mobu.services.business.tap.TAPBusiness(*, options, user, events, logger, flock)

Bases: Business, Generic

Base class for business that executes TAP query.

This class modifies the core Business loop by providing startup, execute, and shutdown methods that know how to execute TAP queries. Subclasses must override get_next_query to return the next query they want to execute.

Parameters:

• options (TypeVar(T, bound= TAPBusinessOptions)) – Configuration options for the business.

• user (AuthenticatedUser) – User with their authentication token to use to run the business.

• events (Events) – Event publishers.

• logger (BoundLogger) – Logger to use to report the results of business.

• flock (str | None)

Methods Summary

dump()
execute()	Execute the core of each business loop.
get_next_query()	Get the next TAP query to run.
run_query(query)	Run a TAP query either synchronously or asynchronously.
startup()	Run before the start of the first iteration and then not again.

Methods Documentation

dump()

Return type:

TAPBusinessData

async execute()

Execute the core of each business loop.

Return type:

None

abstract get_next_query()

Get the next TAP query to run.

Returns:

TAP query as a string.

Return type:

str

async run_query(query)

Run a TAP query either synchronously or asynchronously.

Parameters:

query (str) – Query string to execute.

Return type:

None

async startup()

Run before the start of the first iteration and then not again.

Return type:

None