---------------------------------------------------------------------------
OSError Traceback (most recent call last)
<ipython-input-3-097abd76aabd> in <module>
5 client = Client("tls://localhost:8786")
6
----> 7 output = processor.run_uproot_job(fileset=fileset,
8 treename="Events",
9 processor_instance=Processor(),
/opt/conda/lib/python3.8/site-packages/coffea/processor/executor.py in run_uproot_job(fileset, treename, processor_instance, executor, executor_args, pre_executor, pre_args, chunksize, maxchunks, metadata_cache)
1066 }
1067 exe_args.update(executor_args)
-> 1068 executor(chunks, closure, wrapped_out, **exe_args)
1069
1070 wrapped_out['metrics']['chunks'] = value_accumulator(int, len(chunks))
/opt/conda/lib/python3.8/site-packages/coffea/processor/executor.py in dask_executor(items, function, accumulator, **kwargs)
622
623 if heavy_input is not None:
--> 624 heavy_token = client.scatter(heavy_input, broadcast=True, hash=False, direct=direct_heavy)
625 items = list(zip(items, repeat(heavy_token)))
626
/opt/conda/lib/python3.8/site-packages/distributed/client.py in scatter(self, data, workers, broadcast, direct, hash, timeout, asynchronous)
2188 else:
2189 local_worker = None
-> 2190 return self.sync(
2191 self._scatter,
2192 data,
/opt/conda/lib/python3.8/site-packages/distributed/client.py in sync(self, func, asynchronous, callback_timeout, *args, **kwargs)
831 return future
832 else:
--> 833 return sync(
834 self.loop, func, *args, callback_timeout=callback_timeout, **kwargs
835 )
/opt/conda/lib/python3.8/site-packages/distributed/utils.py in sync(loop, func, callback_timeout, *args, **kwargs)
337 if error[0]:
338 typ, exc, tb = error[0]
--> 339 raise exc.with_traceback(tb)
340 else:
341 return result[0]
/opt/conda/lib/python3.8/site-packages/distributed/utils.py in f()
321 if callback_timeout is not None:
322 future = asyncio.wait_for(future, callback_timeout)
--> 323 result[0] = yield future
324 except Exception as exc:
325 error[0] = sys.exc_info()
/opt/conda/lib/python3.8/site-packages/tornado/gen.py in run(self)
733
734 try:
--> 735 value = future.result()
736 except Exception:
737 exc_info = sys.exc_info()
/opt/conda/lib/python3.8/site-packages/distributed/client.py in _scatter(self, data, workers, broadcast, direct, local_worker, timeout, hash)
2079 )
2080 else:
-> 2081 await self.scheduler.scatter(
2082 data=data2,
2083 workers=workers,
/opt/conda/lib/python3.8/site-packages/distributed/core.py in send_recv_from_rpc(**kwargs)
881 name, comm.name = comm.name, "ConnectionPool." + key
882 try:
--> 883 result = await send_recv(comm=comm, op=key, **kwargs)
884 finally:
885 self.pool.reuse(self.addr, comm)
/opt/conda/lib/python3.8/site-packages/distributed/core.py in send_recv(comm, reply, serializers, deserializers, **kwargs)
680 if comm.deserialize:
681 typ, exc, tb = clean_exception(**response)
--> 682 raise exc.with_traceback(tb)
683 else:
684 raise Exception(response["text"])
/opt/conda/lib/python3.8/site-packages/distributed/core.py in handle_comm()
526 result = asyncio.ensure_future(result)
527 self._ongoing_coroutines.add(result)
--> 528 result = await result
529 except (CommClosedError, CancelledError) as e:
530 if self.status == Status.running:
/opt/conda/lib/python3.8/site-packages/distributed/scheduler.py in scatter()
2852 else:
2853 n = broadcast
-> 2854 await self.replicate(keys=keys, workers=workers, n=n)
2855
2856 self.log_event(
/opt/conda/lib/python3.8/site-packages/distributed/scheduler.py in replicate()
3284 ]
3285
-> 3286 results = await asyncio.gather(
3287 *(
3288 retry_operation(self.rpc(addr=w).gather, who_has=who_has)
/opt/conda/lib/python3.8/site-packages/distributed/utils_comm.py in retry_operation()
383 dask.config.get("distributed.comm.retry.delay.max"), default="s"
384 )
--> 385 return await retry(
386 partial(coro, *args, **kwargs),
387 count=retry_count,
/opt/conda/lib/python3.8/site-packages/distributed/utils_comm.py in retry()
368 delay *= 1 + random.random() * jitter_fraction
369 await asyncio.sleep(delay)
--> 370 return await coro()
371
372
/opt/conda/lib/python3.8/site-packages/distributed/core.py in send_recv_from_rpc()
878 if self.deserializers is not None and kwargs.get("deserializers") is None:
879 kwargs["deserializers"] = self.deserializers
--> 880 comm = await self.pool.connect(self.addr)
881 name, comm.name = comm.name, "ConnectionPool." + key
882 try:
/opt/conda/lib/python3.8/site-packages/distributed/core.py in connect()
1029
1030 try:
-> 1031 comm = await connect(
1032 addr,
1033 timeout=timeout or self.timeout,
/opt/conda/lib/python3.8/site-packages/distributed/comm/core.py in connect()
332 backoff = min(backoff, 1) # wait at most one second
333 else:
--> 334 _raise(error)
335 else:
336 break
/opt/conda/lib/python3.8/site-packages/distributed/comm/core.py in _raise()
273 error,
274 )
--> 275 raise IOError(msg)
276
277 backoff = 0.01
OSError: Timed out trying to connect to 'tls://129.93.183.30:8786' after 10 s: Timed out trying to connect to 'tls://129.93.183.30:8786' after 10 s: [SSL: CERTIFICATE_VERIFY_FAILED] certificate verify failed: self signed certificate (_ssl.c:1123)