Skip to content

Instantly share code, notes, and snippets.

Show Gist options
  • Save ranchodeluxe/ec7e634b824eda6b5d47bae18cacda4e to your computer and use it in GitHub Desktop.
Save ranchodeluxe/ec7e634b824eda6b5d47bae18cacda4e to your computer and use it in GitHub Desktop.
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)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment