Let me know if you really do need emails entirely in plaintext. It seems there was a fix AIRFLOW-1074 which prevents tasks which a worker rejected from getting orphaned and queued indefinitely. Here's a link to the commit <https://github.com/apache/incubator-airflow/commit/70024935f24e0ff3d2861c0ccfa69cdd38084b9d> I could find. That fix reads to me as though it was meant to address the FIXME in models <https://github.com/apache/incubator-airflow/blob/cfc2f73c445074e1e09d6ef6a056cd2b33a945da/airflow/models.py#L1355> and possibly also the FIXME in jobs <https://github.com/apache/incubator-airflow/blob/cfc2f73c445074e1e09d6ef6a056cd2b33a945da/airflow/jobs.py#L1967> .
Those messages weren't removed and I'm investigating one case of a job that logged these in my cluster, though we're running 1.8.2. Do I misunderstand the fix, was it considered partial or incomplete? Is there an archive of the discussion around it (I only found one email about someone being told his issue would be fixed in 1.8.2) what would have to be done further to fix and remove the FIXME? Thanks! -- -Daniel Lamblin
