Skip to main content

z4j scheduler adapter for taskiq schedule sources (Apache 2.0)

Project description

z4j-taskiqscheduler

PyPI version Python License

The taskiq-scheduler adapter for z4j.

Surfaces taskiq-scheduler periodic jobs on the dashboard's Schedules page, read, enable, disable, trigger.

Compatibility

  • TaskIQ 0.11+ and <1
  • Python 3.10+

Full per-adapter matrix at https://z4j.dev/reference/compatibility/.

What it ships

Capability Notes
List schedules every job registered with the taskiq-scheduler source
Read by registered name
Enable / disable via consumer-side gating
Trigger now enqueues the task immediately, outside the schedule
Boot inventory full snapshot at agent connect; existing schedules show up without editing

taskiq-scheduler schedules are typically defined declaratively (label source, JSON file, or label decorators), so create / update / delete are intentionally out of scope, those need a deploy round-trip.

Install

pip install z4j-taskiq z4j-taskiqscheduler
from taskiq import TaskiqScheduler
from taskiq.schedule_sources import LabelScheduleSource
from z4j_bare import install_agent
from z4j_taskiq import TaskiqEngineAdapter
from z4j_taskiqscheduler import TaskiqSchedulerAdapter

scheduler = TaskiqScheduler(
    broker=broker,
    sources=[LabelScheduleSource(broker)],
)

install_agent(
    engines=[TaskiqEngineAdapter(broker=broker)],
    schedulers=[TaskiqSchedulerAdapter(scheduler=scheduler)],
    brain_url="https://brain.example.com",
    token="z4j_agent_...",
    project_id="my-project",
)

Pairs with

Reliability

  • No exception from the adapter ever propagates back into taskiq-scheduler or your task code.
  • Schedule sources are read-only at runtime; the adapter only observes, it does not rewrite the underlying source.

Documentation

Full docs at z4j.dev/schedulers/taskiq-scheduler/.

License

Apache-2.0, see LICENSE.

Links

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

z4j_taskiqscheduler-1.6.7.tar.gz (11.5 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

z4j_taskiqscheduler-1.6.7-py3-none-any.whl (9.2 kB view details)

Uploaded Python 3

File details

Details for the file z4j_taskiqscheduler-1.6.7.tar.gz.

File metadata

  • Download URL: z4j_taskiqscheduler-1.6.7.tar.gz
  • Upload date:
  • Size: 11.5 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.2.0 CPython/3.14.4

File hashes

Hashes for z4j_taskiqscheduler-1.6.7.tar.gz
Algorithm Hash digest
SHA256 298e8e85a6d468c24539047022c833a131d86b95923deae1dc87f20fa7bb34fe
MD5 18ac9571c271780ae0acc5d0f060576d
BLAKE2b-256 041de737e6623af530eefb2a331329e2126b162d213b3ec315c0f5efcb662191

See more details on using hashes here.

File details

Details for the file z4j_taskiqscheduler-1.6.7-py3-none-any.whl.

File metadata

File hashes

Hashes for z4j_taskiqscheduler-1.6.7-py3-none-any.whl
Algorithm Hash digest
SHA256 a41eab234d39c49cf856ab904196796657f23d3fd3b280efacf94ab1ec220e30
MD5 a66f5900c52b59d29a7f099423d941be
BLAKE2b-256 bb5bb81b4c7ccd12a0616f602f0bf5bcda5c4cb44b0b0e5778bc43808068250e

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page