search

LamaAni / KubernetesJobOperator

An airflow operator that executes a task in a kubernetes cluster, given a kubernetes yaml configuration or an image refrence.
58 stars 8 forks source link

Second logs cleanup #16

Closed LamaAni closed 4 years ago

LamaAni commented 4 years ago

Fixes:

  1. JobRunner detect when object was deleted manually and error without timeout.
  2. Changed Query status to an object KubeApiRestQueryConnectionState
  3. Fix for error in Job failure. The.job may fail before it was even scheduled.
  4. Fix for since in GetLogs (appropriate times now)
  5. Fix for client reconnect, Throwing appropriate errors now.
  6. Fix for watcher, added force stop background loggers on stop/query end.
  7. Updated tests.