# Requires: pip install tensorflow==2.0.0 tensorflow-transform==0.15.0 import io import threading import pickle encoded = b'' bytes_io = io.BytesIO(encoded) unpickler = pickle.Unpickler(bytes_io) def find_class(module_name, class_name): return unpickler.find_class(module_name, class_name) def t1(): return find_class("tensorflow_transform.beam.analyzer_impls", "_PackedCombinerWrapper") def t2(): return find_class("tensorflow_transform.tf_metadata.metadata_io", "write_metadata") threads = [] threads.append(threading.Thread(target=t1)) threads.append(threading.Thread(target=t2)) for thread in threads: thread.start()