We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8138c6a commit 1e2b71fCopy full SHA for 1e2b71f
tensorflow_transform/py_func/pyfunc_helper.py
@@ -15,6 +15,7 @@
15
16
import dill
17
import tensorflow as tf
18
+from tfx_bsl import beam as tfx_bsl_beam
19
# TODO(b/243513856): Switch to `collections.namedtuple` or `typing.NamedTuple`
20
# once the Spark issue is resolved.
21
from tfx_bsl.types import tfx_namedtuple
@@ -26,6 +27,8 @@
26
27
28
_PYFUNC_COLLECTION_KEY = 'pyfuncs'
29
30
+tfx_bsl_beam.fix_code_type_pickling()
31
+
32
33
class _PyFuncDef(tfx_namedtuple.namedtuple('_PyFuncDef', ['token', 'func'])):
34
"""An internal wrapper around tuple(token, func).
0 commit comments