Skip to content

Open handles not properly cleaned up #613

Closed
Bug
#712
Closed
Open handles not properly cleaned up#613
Bug
#712
Labels
v1

Description

@BrianMichell
BrianMichell
opened on Aug 26, 2025

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()]>>

No activity

Activity on this issue will appear here.

Activity

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Metadata

Metadata

Assignees

No one assigned

    Labels

    v1

    Type

    Bug

    Projects

    No projects

      Milestone

      No milestone

      Relationships

      None yet

      Development

      No branches or pull requests

      Issue actions