pcolladosoto commented on a change in pull request #22685:
URL: https://github.com/apache/airflow/pull/22685#discussion_r841061265
##########
File path: airflow/dag_processing/processor.py
##########
@@ -231,6 +231,9 @@ def _kill_process(self) -> None:
if self._process.is_alive() and self._process.pid:
self.log.warning("Killing DAGFileProcessorProcess (PID=%d)",
self._process.pid)
os.kill(self._process.pid, signal.SIGKILL)
+
+ # Reap the spawned zombie
+ os.waitpid(self._process.pid, 0)
Review comment:
Hi @malthe! I just pushed the changes: I decided to import the `time`
module so that I could call `time.sleep()` within the `while` loop. Hope I made
the right choice... You can check out the changes on 27502be2e2a8db81. Thanks a
lot for the input! This is something that I'm sure will come in handy for
future projects 😸
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
