gistfile1.txt

Thread 9160 (idle): "MainThread"
    wait (threading.py:331)
    _wait_once (grpc/_common.py:116)
    wait (grpc/_common.py:156)
    _next (grpc/_channel.py:959)
    __next__ (grpc/_channel.py:542)
    run (apache_beam/runners/worker/sdk_worker.py:262)
    main (apache_beam/runners/worker/sdk_worker_main.py:212)
    <module> (apache_beam/runners/worker/sdk_worker_main.py:367)
    _run_code (<frozen runpy>:88)
    _run_module_as_main (<frozen runpy>:198)
Thread 9177 (idle): "read_log_control_messages"
    wait (threading.py:331)
    _wait_once (grpc/_common.py:116)
    wait (grpc/_common.py:156)
    _next (grpc/_channel.py:959)
    __next__ (grpc/_channel.py:542)
    _read_log_control_messages (apache_beam/runners/worker/log_handler.py:216)
    <lambda> (apache_beam/runners/worker/log_handler.py:99)
    run (threading.py:982)
    _bootstrap_inner (threading.py:1045)
    _bootstrap (threading.py:1002)
Thread 9179 (idle): "Thread-5 (_run)"
    channel_spin (grpc/_channel.py:1728)
    run (threading.py:982)
    _bootstrap_inner (threading.py:1045)
    _bootstrap (threading.py:1002)
Thread 9180 (idle): "Thread-6 (_run)"
    wait (threading.py:327)
    get (queue.py:171)
    _write_log_entries (apache_beam/runners/worker/log_handler.py:182)
    consume_request_iterator (grpc/_channel.py:275)
    run (threading.py:982)
    _bootstrap_inner (threading.py:1045)
    _bootstrap (threading.py:1002)
Thread 9184 (idle): "Thread-10"
    wait (threading.py:331)
    wait (threading.py:629)
    run (apache_beam/runners/worker/data_plane.py:224)
    _bootstrap_inner (threading.py:1045)
    _bootstrap (threading.py:1002)
Thread 9185 (idle): "Thread-11 (_run)"
    channel_spin (grpc/_channel.py:1728)
    run (threading.py:982)
    _bootstrap_inner (threading.py:1045)
    _bootstrap (threading.py:1002)
Thread 9186 (idle): "Thread-12 (_run)"
    wait (threading.py:327)
    get (queue.py:171)
    get_responses (apache_beam/runners/worker/sdk_worker.py:254)
    consume_request_iterator (grpc/_channel.py:275)
    run (threading.py:982)
    _bootstrap_inner (threading.py:1045)
    _bootstrap (threading.py:1002)
Thread 9189 (idle): "Thread-13"
    wait (threading.py:331)
    wait (threading.py:629)
    sync (fsspec/asyn.py:91)
    _fetch_range (s3fs/core.py:2462)
    _fetch_range (s3fs/core.py:2300)
    _fetch (fsspec/caching.py:69)
    read (fsspec/spec.py:1846)
    readinto (fsspec/spec.py:1856)
    __getitem__ (h5py/_hl/dataset.py:758)
    __getitem__ (h5netcdf/core.py:347)
    _getitem (xarray/backends/h5netcdf_.py:56)
    explicit_indexing_adapter (xarray/core/indexing.py:861)
    __getitem__ (xarray/backends/h5netcdf_.py:49)
    get_duck_array (xarray/core/indexing.py:554)
    get_duck_array (xarray/core/indexing.py:490)
    __array__ (xarray/core/indexing.py:487)
    to_duck_array (xarray/core/pycompat.py:140)
    first_n_items (xarray/core/formatting.py:90)
    _decode_cf_datetime_dtype (xarray/coding/times.py:209)
    decode (xarray/coding/times.py:832)
    decode_cf_variable (xarray/conventions.py:287)
    decode_cf_variables (xarray/conventions.py:436)
    open_dataset (xarray/backends/store.py:46)
    open_dataset (xarray/backends/h5netcdf_.py:414)
    open_dataset (xarray/backends/api.py:572)
    open_with_xarray (pangeo_forge_recipes/openers.py:238)
    <lambda> (pangeo_forge_recipes/transforms.py:235)
    <lambda> (apache_beam/transforms/core.py:2040)
    process_encoded (apache_beam/runners/worker/bundle_processor.py:237)
    process_bundle (apache_beam/runners/worker/bundle_processor.py:1056)
    process_bundle (apache_beam/runners/worker/sdk_worker.py:663)
    do_instruction (apache_beam/runners/worker/sdk_worker.py:625)
    <lambda> (apache_beam/runners/worker/sdk_worker.py:372)
    _execute (apache_beam/runners/worker/sdk_worker.py:297)
    task (apache_beam/runners/worker/sdk_worker.py:371)
    run (apache_beam/utils/thread_pool_executor.py:37)
    run (apache_beam/utils/thread_pool_executor.py:53)
    _bootstrap_inner (threading.py:1045)
    _bootstrap (threading.py:1002)
Thread 9191 (idle): "Thread-14 (_run)"
    channel_spin (grpc/_channel.py:1728)
    run (threading.py:982)
    _bootstrap_inner (threading.py:1045)
    _bootstrap (threading.py:1002)
Thread 9192 (idle): "Thread-15 (_run)"
    wait (threading.py:327)
    get (queue.py:171)
    request_iter (apache_beam/runners/worker/sdk_worker.py:1025)
    consume_request_iterator (grpc/_channel.py:275)
    run (threading.py:982)
    _bootstrap_inner (threading.py:1045)
    _bootstrap (threading.py:1002)
Thread 9193 (idle): "read_state"
    wait (threading.py:331)
    _wait_once (grpc/_common.py:116)
    wait (grpc/_common.py:156)
    _next (grpc/_channel.py:959)
    __next__ (grpc/_channel.py:542)
    pull_responses (apache_beam/runners/worker/sdk_worker.py:1035)
    run (threading.py:982)
    _bootstrap_inner (threading.py:1045)
    _bootstrap (threading.py:1002)
Thread 9194 (idle): "Thread-16 (_run)"
    channel_spin (grpc/_channel.py:1728)
    run (threading.py:982)
    _bootstrap_inner (threading.py:1045)
    _bootstrap (threading.py:1002)
Thread 9195 (idle): "Thread-17 (_run)"
    wait (threading.py:327)
    get (queue.py:171)
    _write_outputs (apache_beam/runners/worker/data_plane.py:591)
    consume_request_iterator (grpc/_channel.py:275)
    run (threading.py:982)
    _bootstrap_inner (threading.py:1045)
    _bootstrap (threading.py:1002)
Thread 9196 (idle): "read_grpc_client_inputs"
    wait (threading.py:331)
    _wait_once (grpc/_common.py:116)
    wait (grpc/_common.py:156)
    _next (grpc/_channel.py:959)
    __next__ (grpc/_channel.py:542)
    _read_inputs (apache_beam/runners/worker/data_plane.py:652)
    <lambda> (apache_beam/runners/worker/data_plane.py:669)
    run (threading.py:982)
    _bootstrap_inner (threading.py:1045)
    _bootstrap (threading.py:1002)
Thread 9202 (idle): "Thread-19 (run)"
    run (threading.py:982)
    _bootstrap_inner (threading.py:1045)
    _bootstrap (threading.py:1002)
Thread 9203 (idle): "fsspecIO"
    close (h5py/_hl/files.py:573)
    close (h5netcdf/core.py:1203)
    close (xarray/backends/file_manager.py:234)
    __del__ (xarray/backends/file_manager.py:250)
    _writer (aiohttp/client_reqrep.py:355)
    send (aiohttp/client_reqrep.py:715)
    _request (aiohttp/client.py:603)
    send (aiobotocore/httpsession.py:223)
    _send (aiobotocore/endpoint.py:285)
    _do_get_response (aiobotocore/endpoint.py:181)
    _get_response (aiobotocore/endpoint.py:139)
    _send_request (aiobotocore/endpoint.py:97)
    _make_request (aiobotocore/client.py:416)
    _make_api_call (aiobotocore/client.py:388)
    _error_wrapper (s3fs/core.py:113)
    _call_s3 (s3fs/core.py:362)
    _call_and_read (s3fs/core.py:2467)
    _error_wrapper (s3fs/core.py:113)
    _inner_fetch (s3fs/core.py:2480)
    _runner (fsspec/asyn.py:56)
    _run (asyncio/events.py:84)
    _run_once (asyncio/base_events.py:1936)
    run_forever (asyncio/base_events.py:608)
    run (threading.py:982)
    _bootstrap_inner (threading.py:1045)
    _bootstrap (threading.py:1002)
Thread 9204 (idle): "asyncio_0"
    _worker (concurrent/futures/thread.py:81)
    run (threading.py:982)
    _bootstrap_inner (threading.py:1045)
    _bootstrap (threading.py:1002)