tanjun.schedules#

Copy the schedule.

Returns:

• Self –

  The copied schedule.

Raises:

• RuntimeError –

  If the schedule is active.

Stop the schedule while cancelling any active tasks.

Raises:

• RuntimeError –

  If the schedule is not active.

Start the schedule.

Parameters:

• client (Client) –

  The injector client calls should be resolved with.

• loop (Optional[AbstractEventLoop], default: None ) –

  The event loop to use. If not provided, the current event loop will be used.

Raises:

• RuntimeError –

  If the scheduled callback is already running. If the current or provided event loop isn't running.

Stop the schedule after waiting for any existing tasks to finish.

Raises:

• RuntimeError –

  If the scheduled callback isn't running.

Initialise an interval schedule.

Parameters:

• callback (Callable[..., Coroutine[Any, Any, None]]) –

  The callback for the schedule.

  This should be an asynchronous function which takes no positional arguments, returns None and may use dependency injection.

• interval (Union[timedelta, int, float]) –

  The interval between calls. Passed as a timedelta, or a number of seconds.

• fatal_exceptions (Sequence[type[Exception]], default: () ) –

  A sequence of exceptions that will cause the schedule to stop if raised by the callback, start callback or stop callback.

• ignored_exceptions (Sequence[type[Exception]], default: () ) –

  A sequence of exceptions that should be ignored if raised by the callback, start callback or stop callback.

• max_runs (Optional[int], default: None ) –

  The maximum amount of times the schedule runs.

Set the exceptions that will stop a schedule.

If any of these exceptions are encountered, the task will stop.

Parameters:

• *exceptions (type[Exception], default: () ) –

  Types of the exceptions to stop the task on.

Returns:

• Self –

  The schedule object to enable chianed calls.

Set the exceptions that a schedule will ignore.

If any of these exceptions are encountered, there will be nothing printed to console.

Parameters:

• *exceptions (type[Exception], default: () ) –

  Types of the exceptions to ignore.

Returns:

• Self –

  The schedule object to enable chained calls.

Set the callback executed before the schedule starts to run.

Parameters:

• callback (_CallbackSig) –

  The callback to set.

Returns:

• Self –

  The schedule instance to enable chained calls.

Set the callback executed after the schedule is finished.

Parameters:

• callback (_CallbackSig) –

  The callback to set.

Returns:

• Self –

  The schedule instance to enable chained calls.

Set the callback executed before the schedule is finished/stopped.

Parameters:

• callback (Callable[..., Coroutine[Any, Any, None]]) –

  The callback to set.

Returns:

• Callable[..., Coroutine[Any, Any, None]] –

  The added callback.

Examples:

@component.with_schedule
@tanjun.as_interval(1, max_runs=20)
async def interval():
    global counter
    counter += 1
    print(f"Run #{counter}")

@interval.with_start_callback
async def pre():
    print("pre callback")

Set the callback executed after the schedule is finished.

Parameters:

• callback (Callable[..., Coroutine[Any, Any, None]]) –

  The callback to set.

Returns:

• Callable[..., Coroutine[Any, Any, None]] –

  The added callback.

Examples:

@component.with_schedule
@tanjun.as_interval(1, max_runs=20)
async def interval():
    global counter
    counter += 1
    print(f"Run #{counter}")


@interval.with_stop_callback
async def post():
    print("pre callback")

Initialise the time schedule.

Parameters:

• callback (Callable[..., Coroutine[Any, Any, None]]) –

  The callback for the schedule.

  This should be an asynchronous function which takes no positional arguments, returns None and may use dependency injection.

• months (Union[int, Sequence[int]], default: () ) –

  Either one or multiple months the schedule shouldrun on.

  If this is not specified or an empty sequence then the schedule will run on all months.

• weekly (bool, default: False ) –

  Whether the schedule should run on a weekly basis.

• days (Union[int, Sequence[int]], default: () ) –

  Either one or multiple days the schedule should run on.

  When weekly is True, days will refer to the days of the week (range(7)).

  Otherwise this will refer to the days of the month (range(32)). For months where less than 31 days exist, numbers which are too large will be ignored.

  If this is not specified or an empty sequence, then the schedule will run on all days.

• hours (Union[int, Sequence[int]], default: () ) –

  Either one or multiple hours the schedule should run on.

  If this is not specified or an empty sequence then the schedule will run on all hours.

• minutes (Union[int, Sequence[int]], default: () ) –

  Either one or multiple minutes the schedule should run on.

  If this is not specified or an empty sequence then the schedule will run on all minutes.

• seconds (Union[int, Sequence[int]], default: 0 ) –

  Either one or multiple seconds the schedule should run on.

  Defaults to the start of the minute if not specified or an empty sequence.

• fatal_exceptions (Sequence[type[Exception]], default: () ) –

  A sequence of exceptions that will cause the schedule to stop if raised by the callback, start callback or stop callback.

• ignored_exceptions (Sequence[type[Exception]], default: () ) –

  A sequence of exceptions that should be ignored if raised by the callback, start callback or stop callback.

• timezone (Optional[timezone], default: None ) –

  The timezone to use for the schedule.

  If this is not specified then the system's local timezone will be used.

Raises:

• ValueError –

  Raises a value error for any of the following reasons:

  • If months has any values outside the range of range(1, 13).
  • If days has any values outside the range of range(1, 32) when weekly is False or outside the range of range(1, 8) when weekly is True.
  • If hours has any values outside the range of range(0, 24).
  • If minutes has any values outside the range of range(0, 60).
  • If seconds has any values outside the range of range(0, 60).

Set the exceptions that will stop a schedule.

If any of these exceptions are encountered, the task will stop.

Parameters:

• *exceptions (type[Exception], default: () ) –

  Types of the exceptions to stop the task on.

Returns:

• Self –

  The schedule object to enable chianed calls.

Set the exceptions that a schedule will ignore.

If any of these exceptions are encountered, there will be nothing printed to console.

Parameters:

• *exceptions (type[Exception], default: () ) –

  Types of the exceptions to ignore.

Returns:

• Self –

  The schedule object to enable chained calls.