Open handles not properly cleaned up

[BrianMichell]

When ingesting segy_to_mdio in cloud-to-cloud mode file handles do not get properly cleaned up. This leads to many errors being printed to stdout.

These are non-fatal, but can be very misleading.

Scanning SEG-Y for geometry attributes: 100%|██████████| 3013/3013 [02:00<00:00, 24.96block/s]
Ingesting traces: 100%|██████████| 2303/2303 [05:43<00:00,  6.70block/s] 
Traceback (most recent call last):
Traceback (most recent call last):
Traceback (most recent call last):
Traceback (most recent call last):
Traceback (most recent call last):
Traceback (most recent call last):
Traceback (most recent call last):
Traceback (most recent call last):
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 666, in _exitfunc
    f()
    ~^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 590, in __call__
    return info.func(*info.args, **(info.kwargs or {}))
           ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/gcsfs/core.py", line 380, in close_session
    asyn.sync(asyn.loop[0], session.close, timeout=0.1)
    ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 103, in sync
    raise return_result
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 56, in _runner
    result[0] = await coro
                ^^^^^^^^^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/tasks.py", line 507, in wait_for
    return await fut
           ^^^^^^^^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 666, in _exitfunc
    f()
    ~^^
  File ".venv/lib/python3.13/site-packages/aiohttp/client.py", line 1327, in close
    await self._connector.close()
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 590, in __call__
    return info.func(*info.args, **(info.kwargs or {}))
           ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/aiohttp/connector.py", line 1044, in close
    await super().close(abort_ssl=abort_ssl or self._ssl_shutdown_timeout == 0)
  File ".venv/lib/python3.13/site-packages/gcsfs/core.py", line 380, in close_session
    asyn.sync(asyn.loop[0], session.close, timeout=0.1)
    ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 103, in sync
    raise return_result
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 56, in _runner
    result[0] = await coro
                ^^^^^^^^^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/tasks.py", line 507, in wait_for
    return await fut
           ^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/aiohttp/client.py", line 1327, in close
    await self._connector.close()
  File ".venv/lib/python3.13/site-packages/aiohttp/connector.py", line 1044, in close
    await super().close(abort_ssl=abort_ssl or self._ssl_shutdown_timeout == 0)
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 666, in _exitfunc
    f()
    ~^^
RuntimeError: Task <Task pending name='Task-27232' coro=<_runner() running at .venv/lib/python3.13/site-packages/fsspec/asyn.py:56> cb=[_chain_future.<locals>._call_set_state() at uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/futures.py:391]> got Future <Task pending name='Task-27233' coro=<_wait_for_close() running at .venv/lib/python3.13/site-packages/aiohttp/connector.py:138> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>> attached to a different loop
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 590, in __call__
    return info.func(*info.args, **(info.kwargs or {}))
           ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/gcsfs/core.py", line 380, in close_session
    asyn.sync(asyn.loop[0], session.close, timeout=0.1)
    ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
RuntimeError: Task <Task pending name='Task-27048' coro=<_runner() running at .venv/lib/python3.13/site-packages/fsspec/asyn.py:56> cb=[_chain_future.<locals>._call_set_state() at uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/futures.py:391]> got Future <Task pending name='Task-27049' coro=<_wait_for_close() running at .venv/lib/python3.13/site-packages/aiohttp/connector.py:138> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>> attached to a different loop
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 103, in sync
    raise return_result
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 56, in _runner
    result[0] = await coro
                ^^^^^^^^^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/tasks.py", line 507, in wait_for
    return await fut
           ^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/aiohttp/client.py", line 1327, in close
    await self._connector.close()
  File ".venv/lib/python3.13/site-packages/aiohttp/connector.py", line 1044, in close
    await super().close(abort_ssl=abort_ssl or self._ssl_shutdown_timeout == 0)
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 666, in _exitfunc
    f()
    ~^^
RuntimeError: Task <Task pending name='Task-28296' coro=<_runner() running at .venv/lib/python3.13/site-packages/fsspec/asyn.py:56> cb=[_chain_future.<locals>._call_set_state() at uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/futures.py:391]> got Future <Task pending name='Task-28297' coro=<_wait_for_close() running at .venv/lib/python3.13/site-packages/aiohttp/connector.py:138> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>> attached to a different loop
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 590, in __call__
    return info.func(*info.args, **(info.kwargs or {}))
           ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/gcsfs/core.py", line 380, in close_session
    asyn.sync(asyn.loop[0], session.close, timeout=0.1)
    ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 103, in sync
    raise return_result
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 56, in _runner
    result[0] = await coro
                ^^^^^^^^^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/tasks.py", line 507, in wait_for
    return await fut
           ^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/aiohttp/client.py", line 1327, in close
    await self._connector.close()
  File ".venv/lib/python3.13/site-packages/aiohttp/connector.py", line 1044, in close
    await super().close(abort_ssl=abort_ssl or self._ssl_shutdown_timeout == 0)
RuntimeError: Task <Task pending name='Task-27432' coro=<_runner() running at .venv/lib/python3.13/site-packages/fsspec/asyn.py:56> cb=[_chain_future.<locals>._call_set_state() at uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/futures.py:391]> got Future <Task pending name='Task-27433' coro=<_wait_for_close() running at .venv/lib/python3.13/site-packages/aiohttp/connector.py:138> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>> attached to a different loop
Traceback (most recent call last):
Traceback (most recent call last):
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 666, in _exitfunc
    f()
    ~^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 590, in __call__
    return info.func(*info.args, **(info.kwargs or {}))
           ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/gcsfs/core.py", line 380, in close_session
    asyn.sync(asyn.loop[0], session.close, timeout=0.1)
    ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 103, in sync
    raise return_result
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 56, in _runner
    result[0] = await coro
                ^^^^^^^^^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/tasks.py", line 507, in wait_for
    return await fut
           ^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/aiohttp/client.py", line 1327, in close
    await self._connector.close()
  File ".venv/lib/python3.13/site-packages/aiohttp/connector.py", line 1044, in close
    await super().close(abort_ssl=abort_ssl or self._ssl_shutdown_timeout == 0)
RuntimeError: Task <Task pending name='Task-28147' coro=<_runner() running at .venv/lib/python3.13/site-packages/fsspec/asyn.py:56> cb=[_chain_future.<locals>._call_set_state() at uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/futures.py:391]> got Future <Task pending name='Task-28148' coro=<_wait_for_close() running at .venv/lib/python3.13/site-packages/aiohttp/connector.py:138> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>> attached to a different loop
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 666, in _exitfunc
    f()
    ~^^
Traceback (most recent call last):
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 590, in __call__
    return info.func(*info.args, **(info.kwargs or {}))
           ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/gcsfs/core.py", line 380, in close_session
    asyn.sync(asyn.loop[0], session.close, timeout=0.1)
    ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 103, in sync
    raise return_result
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 56, in _runner
    result[0] = await coro
                ^^^^^^^^^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/tasks.py", line 507, in wait_for
    return await fut
           ^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/aiohttp/client.py", line 1327, in close
    await self._connector.close()
  File ".venv/lib/python3.13/site-packages/aiohttp/connector.py", line 1044, in close
    await super().close(abort_ssl=abort_ssl or self._ssl_shutdown_timeout == 0)
Traceback (most recent call last):
RuntimeError: Task <Task pending name='Task-27385' coro=<_runner() running at .venv/lib/python3.13/site-packages/fsspec/asyn.py:56> cb=[_chain_future.<locals>._call_set_state() at uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/futures.py:391]> got Future <Task pending name='Task-27386' coro=<_wait_for_close() running at .venv/lib/python3.13/site-packages/aiohttp/connector.py:138> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>> attached to a different loop
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 666, in _exitfunc
    f()
    ~^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 590, in __call__
    return info.func(*info.args, **(info.kwargs or {}))
           ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/gcsfs/core.py", line 380, in close_session
    asyn.sync(asyn.loop[0], session.close, timeout=0.1)
    ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 103, in sync
    raise return_result
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 666, in _exitfunc
    f()
    ~^^
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 56, in _runner
    result[0] = await coro
                ^^^^^^^^^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 590, in __call__
    return info.func(*info.args, **(info.kwargs or {}))
           ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/tasks.py", line 507, in wait_for
    return await fut
           ^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/gcsfs/core.py", line 380, in close_session
    asyn.sync(asyn.loop[0], session.close, timeout=0.1)
    ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 103, in sync
    raise return_result
  File ".venv/lib/python3.13/site-packages/aiohttp/client.py", line 1327, in close
    await self._connector.close()
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 56, in _runner
    result[0] = await coro
                ^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/aiohttp/connector.py", line 1044, in close
    await super().close(abort_ssl=abort_ssl or self._ssl_shutdown_timeout == 0)
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/tasks.py", line 507, in wait_for
    return await fut
           ^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/aiohttp/client.py", line 1327, in close
    await self._connector.close()
  File ".venv/lib/python3.13/site-packages/aiohttp/connector.py", line 1044, in close
    await super().close(abort_ssl=abort_ssl or self._ssl_shutdown_timeout == 0)
RuntimeError: Task <Task pending name='Task-27972' coro=<_runner() running at .venv/lib/python3.13/site-packages/fsspec/asyn.py:56> cb=[_chain_future.<locals>._call_set_state() at uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/futures.py:391]> got Future <Task pending name='Task-27973' coro=<_wait_for_close() running at .venv/lib/python3.13/site-packages/aiohttp/connector.py:138> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>> attached to a different loop
RuntimeError: Task <Task pending name='Task-27710' coro=<_runner() running at .venv/lib/python3.13/site-packages/fsspec/asyn.py:56> cb=[_chain_future.<locals>._call_set_state() at uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/futures.py:391]> got Future <Task pending name='Task-27711' coro=<_wait_for_close() running at .venv/lib/python3.13/site-packages/aiohttp/connector.py:138> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>> attached to a different loop
Traceback (most recent call last):
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 666, in _exitfunc
    f()
    ~^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 590, in __call__
    return info.func(*info.args, **(info.kwargs or {}))
           ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/gcsfs/core.py", line 380, in close_session
    asyn.sync(asyn.loop[0], session.close, timeout=0.1)
    ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 103, in sync
    raise return_result
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 56, in _runner
    result[0] = await coro
                ^^^^^^^^^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/tasks.py", line 507, in wait_for
    return await fut
           ^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/aiohttp/client.py", line 1327, in close
    await self._connector.close()
  File ".venv/lib/python3.13/site-packages/aiohttp/connector.py", line 1044, in close
    await super().close(abort_ssl=abort_ssl or self._ssl_shutdown_timeout == 0)
RuntimeError: Task <Task pending name='Task-27894' coro=<_runner() running at .venv/lib/python3.13/site-packages/fsspec/asyn.py:56> cb=[_chain_future.<locals>._call_set_state() at uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/futures.py:391]> got Future <Task pending name='Task-27895' coro=<_wait_for_close() running at .venv/lib/python3.13/site-packages/aiohttp/connector.py:138> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>> attached to a different loop
Traceback (most recent call last):
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 666, in _exitfunc
    f()
    ~^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 590, in __call__
    return info.func(*info.args, **(info.kwargs or {}))
           ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/gcsfs/core.py", line 380, in close_session
    asyn.sync(asyn.loop[0], session.close, timeout=0.1)
    ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 103, in sync
    raise return_result
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 56, in _runner
    result[0] = await coro
                ^^^^^^^^^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/tasks.py", line 507, in wait_for
    return await fut
           ^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/aiohttp/client.py", line 1327, in close
    await self._connector.close()
  File ".venv/lib/python3.13/site-packages/aiohttp/connector.py", line 1044, in close
    await super().close(abort_ssl=abort_ssl or self._ssl_shutdown_timeout == 0)
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 666, in _exitfunc
    f()
    ~^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 590, in __call__
    return info.func(*info.args, **(info.kwargs or {}))
           ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/gcsfs/core.py", line 380, in close_session
    asyn.sync(asyn.loop[0], session.close, timeout=0.1)
    ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
RuntimeError: Task <Task pending name='Task-26976' coro=<_runner() running at .venv/lib/python3.13/site-packages/fsspec/asyn.py:56> cb=[_chain_future.<locals>._call_set_state() at uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/futures.py:391]> got Future <Task pending name='Task-26977' coro=<_wait_for_close() running at .venv/lib/python3.13/site-packages/aiohttp/connector.py:138> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>> attached to a different loop
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 103, in sync
    raise return_result
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 56, in _runner
    result[0] = await coro
                ^^^^^^^^^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/tasks.py", line 507, in wait_for
    return await fut
           ^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/aiohttp/client.py", line 1327, in close
    await self._connector.close()
  File ".venv/lib/python3.13/site-packages/aiohttp/connector.py", line 1044, in close
    await super().close(abort_ssl=abort_ssl or self._ssl_shutdown_timeout == 0)
RuntimeError: Task <Task pending name='Task-27463' coro=<_runner() running at .venv/lib/python3.13/site-packages/fsspec/asyn.py:56> cb=[_chain_future.<locals>._call_set_state() at uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/futures.py:391]> got Future <Task pending name='Task-27464' coro=<_wait_for_close() running at .venv/lib/python3.13/site-packages/aiohttp/connector.py:138> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>> attached to a different loop
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 666, in _exitfunc
    f()
    ~^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 590, in __call__
    return info.func(*info.args, **(info.kwargs or {}))
           ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/gcsfs/core.py", line 380, in close_session
    asyn.sync(asyn.loop[0], session.close, timeout=0.1)
    ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 103, in sync
    raise return_result
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 56, in _runner
    result[0] = await coro
                ^^^^^^^^^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/tasks.py", line 507, in wait_for
    return await fut
           ^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/aiohttp/client.py", line 1327, in close
    await self._connector.close()
  File ".venv/lib/python3.13/site-packages/aiohttp/connector.py", line 1044, in close
    await super().close(abort_ssl=abort_ssl or self._ssl_shutdown_timeout == 0)
RuntimeError: Task <Task pending name='Task-27925' coro=<_runner() running at .venv/lib/python3.13/site-packages/fsspec/asyn.py:56> cb=[_chain_future.<locals>._call_set_state() at uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/futures.py:391]> got Future <Task pending name='Task-27926' coro=<_wait_for_close() running at .venv/lib/python3.13/site-packages/aiohttp/connector.py:138> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>> attached to a different loop
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 666, in _exitfunc
    f()
    ~^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 590, in __call__
    return info.func(*info.args, **(info.kwargs or {}))
           ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/gcsfs/core.py", line 380, in close_session
    asyn.sync(asyn.loop[0], session.close, timeout=0.1)
    ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 103, in sync
    raise return_result
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 56, in _runner
    result[0] = await coro
                ^^^^^^^^^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/tasks.py", line 507, in wait_for
    return await fut
           ^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/aiohttp/client.py", line 1327, in close
    await self._connector.close()
  File ".venv/lib/python3.13/site-packages/aiohttp/connector.py", line 1044, in close
    await super().close(abort_ssl=abort_ssl or self._ssl_shutdown_timeout == 0)
RuntimeError: Task <Task pending name='Task-26998' coro=<_runner() running at .venv/lib/python3.13/site-packages/fsspec/asyn.py:56> cb=[_chain_future.<locals>._call_set_state() at uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/futures.py:391]> got Future <Task pending name='Task-26999' coro=<_wait_for_close() running at .venv/lib/python3.13/site-packages/aiohttp/connector.py:138> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>> attached to a different loop
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 666, in _exitfunc
    f()
    ~^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 590, in __call__
    return info.func(*info.args, **(info.kwargs or {}))
           ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/gcsfs/core.py", line 380, in close_session
    asyn.sync(asyn.loop[0], session.close, timeout=0.1)
    ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 103, in sync
    raise return_result
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 56, in _runner
    result[0] = await coro
                ^^^^^^^^^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/tasks.py", line 507, in wait_for
    return await fut
           ^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/aiohttp/client.py", line 1327, in close
    await self._connector.close()
  File ".venv/lib/python3.13/site-packages/aiohttp/connector.py", line 1044, in close
    await super().close(abort_ssl=abort_ssl or self._ssl_shutdown_timeout == 0)
RuntimeError: Task <Task pending name='Task-27204' coro=<_runner() running at .venv/lib/python3.13/site-packages/fsspec/asyn.py:56> cb=[_chain_future.<locals>._call_set_state() at uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/futures.py:391]> got Future <Task pending name='Task-27205' coro=<_wait_for_close() running at .venv/lib/python3.13/site-packages/aiohttp/connector.py:138> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>> attached to a different loop
Traceback (most recent call last):
Traceback (most recent call last):
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 666, in _exitfunc
    f()
    ~^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 590, in __call__
    return info.func(*info.args, **(info.kwargs or {}))
           ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/gcsfs/core.py", line 380, in close_session
    asyn.sync(asyn.loop[0], session.close, timeout=0.1)
    ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 103, in sync
    raise return_result
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 56, in _runner
    result[0] = await coro
                ^^^^^^^^^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/tasks.py", line 507, in wait_for
    return await fut
           ^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/aiohttp/client.py", line 1327, in close
    await self._connector.close()
  File ".venv/lib/python3.13/site-packages/aiohttp/connector.py", line 1044, in close
    await super().close(abort_ssl=abort_ssl or self._ssl_shutdown_timeout == 0)
RuntimeError: Task <Task pending name='Task-22478' coro=<_runner() running at .venv/lib/python3.13/site-packages/fsspec/asyn.py:56> cb=[_chain_future.<locals>._call_set_state() at uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/futures.py:391]> got Future <Task pending name='Task-22479' coro=<_wait_for_close() running at .venv/lib/python3.13/site-packages/aiohttp/connector.py:138> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>> attached to a different loop
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 666, in _exitfunc
    f()
    ~^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/weakref.py", line 590, in __call__
    return info.func(*info.args, **(info.kwargs or {}))
           ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/gcsfs/core.py", line 380, in close_session
    asyn.sync(asyn.loop[0], session.close, timeout=0.1)
    ~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 103, in sync
    raise return_result
  File ".venv/lib/python3.13/site-packages/fsspec/asyn.py", line 56, in _runner
    result[0] = await coro
                ^^^^^^^^^^
  File "uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/tasks.py", line 507, in wait_for
    return await fut
           ^^^^^^^^^
  File ".venv/lib/python3.13/site-packages/aiohttp/client.py", line 1327, in close
    await self._connector.close()
  File ".venv/lib/python3.13/site-packages/aiohttp/connector.py", line 1044, in close
    await super().close(abort_ssl=abort_ssl or self._ssl_shutdown_timeout == 0)
RuntimeError: Task <Task pending name='Task-27682' coro=<_runner() running at .venv/lib/python3.13/site-packages/fsspec/asyn.py:56> cb=[_chain_future.<locals>._call_set_state() at uv/python/cpython-3.13.3-linux-x86_64-gnu/lib/python3.13/asyncio/futures.py:391]> got Future <Task pending name='Task-27683' coro=<_wait_for_close() running at .venv/lib/python3.13/site-packages/aiohttp/connector.py:138> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>> attached to a different loop
Task was destroyed but it is pending!
task: <Task pending name='Task-27973' coro=<_wait_for_close() done, defined at .venv/lib/python3.13/site-packages/aiohttp/connector.py:136> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>>
Task was destroyed but it is pending!
task: <Task pending name='Task-27926' coro=<_wait_for_close() done, defined at .venv/lib/python3.13/site-packages/aiohttp/connector.py:136> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>>
Task was destroyed but it is pending!
task: <Task pending name='Task-28297' coro=<_wait_for_close() done, defined at .venv/lib/python3.13/site-packages/aiohttp/connector.py:136> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>>
Task was destroyed but it is pending!
task: <Task pending name='Task-27049' coro=<_wait_for_close() done, defined at .venv/lib/python3.13/site-packages/aiohttp/connector.py:136> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>>
Task was destroyed but it is pending!
task: <Task pending name='Task-27205' coro=<_wait_for_close() done, defined at .venv/lib/python3.13/site-packages/aiohttp/connector.py:136> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>>
Task was destroyed but it is pending!
task: <Task pending name='Task-28148' coro=<_wait_for_close() done, defined at .venv/lib/python3.13/site-packages/aiohttp/connector.py:136> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>>
Task was destroyed but it is pending!
task: <Task pending name='Task-26977' coro=<_wait_for_close() done, defined at .venv/lib/python3.13/site-packages/aiohttp/connector.py:136> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>>
Task was destroyed but it is pending!
task: <Task pending name='Task-27233' coro=<_wait_for_close() done, defined at .venv/lib/python3.13/site-packages/aiohttp/connector.py:136> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>>
Task was destroyed but it is pending!
task: <Task pending name='Task-27895' coro=<_wait_for_close() done, defined at .venv/lib/python3.13/site-packages/aiohttp/connector.py:136> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>>
Task was destroyed but it is pending!
task: <Task pending name='Task-27464' coro=<_wait_for_close() done, defined at .venv/lib/python3.13/site-packages/aiohttp/connector.py:136> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>>
Task was destroyed but it is pending!
task: <Task pending name='Task-27711' coro=<_wait_for_close() done, defined at .venv/lib/python3.13/site-packages/aiohttp/connector.py:136> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>>
Task was destroyed but it is pending!
task: <Task pending name='Task-27386' coro=<_wait_for_close() done, defined at .venv/lib/python3.13/site-packages/aiohttp/connector.py:136> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>>
Task was destroyed but it is pending!
task: <Task pending name='Task-27433' coro=<_wait_for_close() done, defined at .venv/lib/python3.13/site-packages/aiohttp/connector.py:136> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>>
Task was destroyed but it is pending!
task: <Task pending name='Task-22479' coro=<_wait_for_close() done, defined at .venv/lib/python3.13/site-packages/aiohttp/connector.py:136> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>>
Task was destroyed but it is pending!
task: <Task pending name='Task-27683' coro=<_wait_for_close() done, defined at .venv/lib/python3.13/site-packages/aiohttp/connector.py:136> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>>
Task was destroyed but it is pending!
task: <Task pending name='Task-26999' coro=<_wait_for_close() done, defined at .venv/lib/python3.13/site-packages/aiohttp/connector.py:136> wait_for=<_GatheringFuture pending cb=[Task.task_wakeup()]>>

[dmitriyrepin]

FYI: sometimes I observe the following warning when I run the full set of tests.
I can't locate the origin of the warning since when I enable the 'treat warnings as errors' pytest mode, it disappears:

tests/integration/test_segy_import_export.py: 11 warnings
tests/integration/test_segy_import_export_masked.py: 7 warnings
  /usr/local/lib/python3.13/multiprocessing/popen_fork.py:67: DeprecationWarning: This process (pid=10885) is multi-threaded, use of fork() may lead to deadlocks in the child.
    self.pid = os.fork()