potiuk commented on issue #49887:
URL: https://github.com/apache/airflow/issues/49887#issuecomment-2853440427
I might take a look later, also to get familiar with the code, but possibly
you will know by heart what could be happening - I saw a few cases where we are
closing some sockets forcibly
```python
self._close_unused_sockets(self.stdin)
# Put a message in the viewable task logs
```
```python
@staticmethod
def _close_unused_sockets(*sockets):
"""Close unused ends of sockets after fork."""
for sock in sockets:
if isinstance(sock, SocketIO):
# If we have the socket IO object, we need to close the
underlying socket foricebly here too,
# else we get unclosed socket warnings, and likely leaking
FDs too
sock._sock.close()
sock.close()
```
With the FD leaking possibility mentioned, so I guess that's just another
instance of that one.
--
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]
