Skip to content

feat: async method parity, prefork logging, streaming fixes#36

Merged
pratyush618 merged 3 commits intomasterfrom
feat/async-methods-and-fixes
Mar 22, 2026
Merged

feat: async method parity, prefork logging, streaming fixes#36
pratyush618 merged 3 commits intomasterfrom
feat/async-methods-and-fixes

Conversation

@pratyush618
Copy link
Copy Markdown
Collaborator

Summary

  • 18 missing async methodsaget_job, alist_jobs, alist_jobs_filtered, ajob_dag, ametrics_timeseries, ajob_errors, atask_logs, aquery_logs, acancel_running_job, aenqueue_many, apurge_completed, apurge_dead, arevoke_task, areplay_history, aarchive, alist_archived, apause/aresume, apaused_queues
  • Prefork child logginglogging.getLogger("taskito.prefork.child") with structured log calls for ready, execution, errors, shutdown, teardown failures
  • to_dict() namespace — adds missing namespace field to JobResult.to_dict()
  • Streaming error loggingstream()/astream() now log warnings instead of silently yielding raw strings on deserialization failure

Test plan

  • 357 pass, 9 skipped
  • ruff clean, mypy 0 errors (118 files)

@pratyush618 pratyush618 merged commit e088d9d into master Mar 22, 2026
10 checks passed
@pratyush618 pratyush618 deleted the feat/async-methods-and-fixes branch March 31, 2026 17:22
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant