You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Enable DAG run restarts
Introduce endpoint for whole DAG run restart. Failed DAG run can be
restarted and all failed or not started tasks will be run again.
Change single task logs endpoint to single task details
Change an endpoint introduced in 0.0.8. Instead of serving single DAG
run task logs, now we provide all DAG run task details for that specific
task. That turned out to be better choice from the UI perspective.
New endpoint for DAG run details
- Add scheduler endpoint to provide details on particular DAG run via
/ui/dagrun/{runId}.
- Type dag.NodeInfo now contains both DAG depth and width.
- Table dagtasks now contains additional columns - PosDepth and PosWidth.
- In db package introduced Scannable interface and generic readRowsContext
function.
- Scheduler constructor needs additional argument - tasklog.Factory, to be able
to read task logs.
Introduce FAILED_PENDING_RETRY task status
Fix a bug on FAILED DAG run status in case when the last task in a DAG has
been retried with a success, so DAG run should has also status SUCCESS.
Fix behavior of dag.Attr.CatchUp + schedules table
- Fix behavior related to dag.Attr.CatchUp.
- Introduce `schedules` table in the database, to keep events for schedule
points (`REGULAR`, `SKIPPED`, `CAUGHT_UP`).
Change DRTBase.AtTime from time.Time to string.
Serialized time.Time can differ from the original value on some platform
(e.g. Linux, x86), so when it's used as a key in map, it might cause
really annoying bugs.
v0.0.3 - 2024-08-06
- Introduce `/ui/dagrun/*` endpoints in Scheduler HTTP server, to hydrate the
main UI page.
- Fix counting goroutines in TaskScheduler.
- Introduce `scheduler.API`, so ppacer UI could mock it.