unexpected task call

[parkhomenko-alexander]

Hello everyone! First of all, thanks for the awesome package

I have a problem, but I can't figure out if it's because of my clumsy hands or if I've stumbled upon some bug.

Struct

#broker.py
from taskiq_redis import RedisAsyncResultBackend, RedisStreamBroker
from src.settings import settings
result_backend = RedisAsyncResultBackend(
redis_url=str(settings.REDIS_BACKEND_DSN), )
broker = RedisStreamBroker(
str(settings.REDIS_BROKER_DSN),
"bgu-app"
).with_result_backend(result_backend)
task_tz = "Australia/Brisbane"

#scheduler_entrypoint.py
from taskiq import TaskiqScheduler
from taskiq.schedule_sources import LabelScheduleSource
from src.taskiq_broker.broker import broker
from src.taskiq_broker.tasks.account import ping_task, fetch_bgu_data
scheduler = TaskiqScheduler(
broker=broker,
sources=[LabelScheduleSource(broker)],
)

#worker_entrypoint.py
from src.taskiq_broker.broker import broker as broker
from src.taskiq_broker.tasks.account import ping_task, fetch_bgu_data

In my containers I run a scheduler and a worker like this

uv run taskiq worker src.taskiq_broker.worker_entrypoint:broker -w 1 uv run taskiq scheduler src.taskiq_broker.scheduler_entrypoint:scheduler --skip-first-run

The task (fetch_bgu_data) is programmed to run at 00:00 every day.

But I need to do init during the working day, which I do like this
uv run python -m src.taskiq_broker.cli run task fetch_bgu_data
When i call task task from

#cli.py
import asyncio
from typing import Any
import typer
import pkgutil
import inspect
import importlib
app = typer.Typer()
run_app = typer.Typer() TASKS: dict[str, Any] = {}
for _, module_name, _ in pkgutil.iter_modules(["src/taskiq_broker/tasks"]):
module = importlib.import_module(f"src.taskiq_broker.tasks.{module_name}")
for name, obj in inspect.getmembers(module):
if hasattr(obj, "kiq") and callable(obj.kiq):
TASKS[name] = obj
@run_app.command("task")
def run_task(task_name: str, param: str | None = None):
"""Run any Taskiq task."""
async def _run():
task = TASKS.get(task_name)
if not task:
typer.echo(f"Task '{task_name}' not found.")
raise typer.Exit(1)
kwargs = {}
if param:
kwargs["param"] = param
result = await task.kiq(**kwargs)
typer.echo(f"Task queued with ID: {result.task_id}")
asyncio.run(_run())
app.add_typer(run_app, name="run")
if __name__ == "__main__":
app()

The problem is that during this task, which I run manually, OUTSIDE the scheduler, for the next 30 minutes, the same task starts, please help me figure out what the problem is.

local logs

INFO :: 2025-07-04 04:30:01 :: account:60 :: event=ping_task empty message
INFO :: 2025-07-04 04:30:05 :: fetch_assets:45 :: event=assets_sync updated=3000 created=0 total=330000 page=111
INFO :: 2025-07-04 04:30:12 :: fetch_assets:45 :: event=assets_sync updated=3000 created=0 total=333000 page=112
INFO :: 2025-07-04 04:30:12 :: fetch_assets:55 :: event=assets_sync_commit count=12000
[2025-07-04 04:30:13,193][taskiq.receiver.receiver][INFO ][worker-0] Executing task src.taskiq_broker.tasks.account:fetch_bgu_data with ID: ad3450a868c941ff93ea46efb64b62d2
INFO :: 2025-07-04 04:30:14 :: fetch_accounts:40 :: event=accounts_sync updated=750 created=0 total=0 page=1
INFO :: 2025-07-04 04:30:17 :: fetch_accounts:40 :: event=accounts_sync updated=650 created=0 total=750 page=2
INFO :: 2025-07-04 04:30:18 :: fetch_cmos:40 :: event=cmos_sync updated=750 created=0 total=0 page=1

container logs

bgu-taskiq-worker | INFO :: 2025-07-04 13:13:48 :: fetch_assets:45 :: event=assets_sync updated=3000 created=0 total=357000 page=120
bgu-taskiq-worker | INFO :: 2025-07-04 13:13:48 :: fetch_assets:55 :: event=assets_sync_commit count=12000
bgu-taskiq-worker | INFO :: 2025-07-04 13:13:48 :: fetch_assets:45 :: event=assets_sync updated=3000 created=0 total=177000 page=60
bgu-taskiq-worker | INFO :: 2025-07-04 13:13:48 :: fetch_assets:55 :: event=assets_sync_commit count=12000
bgu-taskiq-worker | [2025-07-04 13:13:48,974][taskiq.receiver.receiver][INFO ][worker-0] Executing task src.taskiq_broker.tasks.account:fetch_bgu_data with ID: 5bca99be7634401e8534b0aab99aff1b
bgu-taskiq-worker | INFO :: 2025-07-04 13:13:50 :: fetch_accounts:40 :: event=accounts_sync updated=750 created=0 total=0 page=1
bgu-taskiq-worker | INFO :: 2025-07-04 13:13:51 :: fetch_accounts:40 :: event=accounts_sync updated=650 created=0 total=750 page=2
bgu-taskiq-worker | INFO :: 2025-07-04 13:13:52 :: fetch_balances:39 :: event=balances_sync created=0 total=12000 page=5
bgu-taskiq-worker | INFO :: 2025-07-04 13:13:53 :: fetch_cmos:40 :: event=cmos_sync updated=750 created=0 total=0 page=1
bgu-taskiq-worker | INFO :: 2025-07-04 13:13:54 :: fetch_balances:39 :: event=balances_sync created=0 total=399000 page=134
bgu-taskiq-worker | INFO :: 2025-07-04 13:13:56 :: fetch_cmos:40 :: event=cmos_sync updated=750 created=0 total=750 page=2
bgu-taskiq-worker | INFO :: 2025-07-04 13:13:57 :: fetch_balances:39 :: event=balances_sync created=0 total=15000 page=6
bgu-taskiq-worker | INFO :: 2025-07-04 13:13:58 :: fetch_cmos:40 :: event=cmos_sync updated=750 created=0 total=1500 page=3