Traceback (most recent call last):


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py", line 170, in _execute

response = task()


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py", line 203, in <lambda>

self._execute(lambda: worker.do_instruction(work), work)


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py", line 360, in do_instruction

request.instruction_id)


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py", line 380, in process_bundle

instruction_id, request.process_bundle_descriptor_id)


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py", line 318, in get

self.data_channel_factory)


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 578, in __init__

self.ops = self.create_execution_tree(self.process_bundle_descriptor)


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 622, in create_execution_tree

descriptor.transforms, key=topological_height, reverse=True)])


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 621, in <listcomp>

for transform_id in sorted(


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 546, in wrapper

result = cache[args] = func(*args)


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 605, in get_operation

in descriptor.transforms[transform_id].outputs.items()


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 604, in <dictcomp>

for tag, pcoll_id


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 603, in <listcomp>

tag: [get_operation(op) for op in pcoll_consumers[pcoll_id]]


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 546, in wrapper

result = cache[args] = func(*args)


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 605, in get_operation

in descriptor.transforms[transform_id].outputs.items()


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 604, in <dictcomp>

for tag, pcoll_id


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 603, in <listcomp>

tag: [get_operation(op) for op in pcoll_consumers[pcoll_id]]


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 546, in wrapper

result = cache[args] = func(*args)


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 605, in get_operation

in descriptor.transforms[transform_id].outputs.items()


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 604, in <dictcomp>

for tag, pcoll_id


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 603, in <listcomp>

tag: [get_operation(op) for op in pcoll_consumers[pcoll_id]]


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 546, in wrapper

result = cache[args] = func(*args)


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 605, in get_operation

in descriptor.transforms[transform_id].outputs.items()


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 604, in <dictcomp>

for tag, pcoll_id


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 603, in <listcomp>

tag: [get_operation(op) for op in pcoll_consumers[pcoll_id]]


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 546, in wrapper

result = cache[args] = func(*args)


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 608, in get_operation

transform_id, transform_consumers)


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 867, in create_operation

return creator(self, transform_id, transform_proto, payload, consumers)


 "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1265, in create

(beam.CombineFn.from_runner_api(payload.combine_fn, factory.context),


 "/usr/local/lib/python3.6/site-packages/apache_beam/utils/urns.py", line 116, in from_runner_api

context)


 "/usr/local/lib/python3.6/site-packages/apache_beam/utils/urns.py", line 90, in <lambda>

lambda proto, unused_context: pickler.loads(proto.value))


 "/usr/local/lib/python3.6/site-packages/apache_beam/internal/pickler.py", line 283, in loads

return dill.loads(s)


 "/usr/local/lib/python3.6/site-packages/dill/_dill.py", line 317, in loads

return load(file, ignore)


 "/usr/local/lib/python3.6/site-packages/dill/_dill.py", line 305, in load

obj = pik.load()


 "/usr/local/lib/python3.6/site-packages/dill/_dill.py", line 474, in find_class

return StockUnpickler.find_class(self, module, name)
ModuleNotFoundError: No module named 'tfx_bsl'

Traceback (most recent call last):


 "D:/GitHub/Deep-Encoding-Pooling-Network-DEP-/train.py", line 172, in <module>

main()


 "D:/GitHub/Deep-Encoding-Pooling-Network-DEP-/train.py", line 45, in main

dataset = importlib.import_module('dataloader.'+args.dataset)


 "C:\anaconda\envs\python36\lib\importlib\__init__.py", line 127, in import_module

return _bootstrap._gcd_import(name[level:], package, level)


 "<frozen importlib._bootstrap>", line 1006, in _gcd_import


 "<frozen importlib._bootstrap>", line 983, in _find_and_load


 "<frozen importlib._bootstrap>", line 965, in _find_and_load_unlocked
ModuleNotFoundError: No module named 'dataloader.minc'
