async def METHOD_NAME(pg: AsyncEngine, tasks_data: TasksData):
    await tasks_data.create(DummyBaseTask)
    await tasks_data.create(DummyTask)
    await tasks_data.create(DummyBaseTask)
    last_run_task = (await tasks_data.find())[0]
    task_spawner_service = TaskSpawnerService(pg, tasks_data)
    tasks = [(DummyBaseTask, 10), (DummyTask, 15)]
    await task_spawner_service.register(tasks)
    assert isclose(
        (
            (
                task_spawner_service.registered[0].last_triggered
                - last_run_task.created_at
            ).total_seconds()
        ),
        0,
        abs_tol=0.8,
    )