@sensor(
    jobs=[
        summarisation_job,
        ...
    ],
    default_status=DefaultSensorStatus.RUNNING,
    description="SQS queue monitor and job factory",
)
def jobs_sensor(context):
    ...
    for message_id, payload in get_sqs_messages(queue_name, sqs):
        <http://context.log.info|context.log.info>(
            f"Processing message {message_id} with payload {pformat(payload)}"
        )
        ...