---------------------------------------------------------------------------
AttributeError Traceback (most recent call last)
Cell In[16], line 2
1 with beam.Pipeline() as p:
----> 2 p | recipe
File ~/miniconda3/envs/runner/lib/python3.9/site-packages/apache_beam/transforms/ptransform.py:614, in PTransform.__ror__(self, left, label)
612 pvalueish = _SetInputPValues().visit(pvalueish, replacements)
613 self.pipeline = p
--> 614 result = p.apply(self, pvalueish, label)
615 if deferred:
616 return result
File ~/miniconda3/envs/runner/lib/python3.9/site-packages/apache_beam/pipeline.py:674, in Pipeline.apply(self, transform, pvalueish, label)
670 # Attempts to alter the label of the transform to be applied only when it's
671 # a top-level transform so that the cell number will not be prepended to
672 # every child transform in a composite.
673 if self._current_transform() is self._root_transform():
--> 674 alter_label_if_ipython(transform, pvalueish)
676 full_label = '/'.join(
677 [self._current_transform().full_label, label or
678 transform.label]).lstrip('/')
679 if full_label in self.applied_labels:
File ~/miniconda3/envs/runner/lib/python3.9/site-packages/apache_beam/utils/interactive_utils.py:71, in alter_label_if_ipython(transform, pvalueish)
59 """Alters the label to an interactive label with ipython prompt metadata
60 prefixed for the given transform if the given pvalueish belongs to a
61 user-defined pipeline and current code execution is within an ipython kernel.
(...)
68 `Cell {prompt}: {original_label}`.
69 """
70 if is_in_ipython():
---> 71 from apache_beam.runners.interactive import interactive_environment as ie
72 # Tracks user defined pipeline instances in watched scopes so that we only
73 # alter labels for any transform to pvalueish belonging to those pipeline
74 # instances, excluding any transform to be applied in other pipeline
75 # instances the Beam SDK creates implicitly.
76 ie.current_env().track_user_pipelines()
File ~/miniconda3/envs/runner/lib/python3.9/site-packages/apache_beam/runners/interactive/interactive_environment.py:41
39 from apache_beam.runners.direct import direct_runner
40 from apache_beam.runners.interactive import cache_manager as cache
---> 41 from apache_beam.runners.interactive.messaging.interactive_environment_inspector import InteractiveEnvironmentInspector
42 from apache_beam.runners.interactive.recording_manager import RecordingManager
43 from apache_beam.runners.interactive.sql.sql_chain import SqlChain
File ~/miniconda3/envs/runner/lib/python3.9/site-packages/apache_beam/runners/interactive/messaging/interactive_environment_inspector.py:26
23 # pytype: skip-file
25 import apache_beam as beam
---> 26 from apache_beam.runners.interactive.utils import as_json
27 from apache_beam.runners.interactive.utils import obfuscate
30 class InteractiveEnvironmentInspector(object):
File ~/miniconda3/envs/runner/lib/python3.9/site-packages/apache_beam/runners/interactive/utils.py:33
30 import pandas as pd
32 import apache_beam as beam
---> 33 from apache_beam.dataframe.convert import to_pcollection
34 from apache_beam.dataframe.frame_base import DeferredBase
35 from apache_beam.internal.gcp import auth
File ~/miniconda3/envs/runner/lib/python3.9/site-packages/apache_beam/dataframe/convert.py:33
31 from apache_beam.dataframe import expressions
32 from apache_beam.dataframe import frame_base
---> 33 from apache_beam.dataframe import transforms
34 from apache_beam.dataframe.schemas import element_typehint_from_dataframe_proxy
35 from apache_beam.dataframe.schemas import generate_proxy
File ~/miniconda3/envs/runner/lib/python3.9/site-packages/apache_beam/dataframe/transforms.py:33
31 from apache_beam import transforms
32 from apache_beam.dataframe import expressions
---> 33 from apache_beam.dataframe import frames # pylint: disable=unused-import
34 from apache_beam.dataframe import partitionings
35 from apache_beam.utils import windowed_value
File ~/miniconda3/envs/runner/lib/python3.9/site-packages/apache_beam/dataframe/frames.py:1231
1224 return func(*args, **kwargs)
1226 return func(self, *args, **kwargs)
1229 @populate_not_implemented(pd.Series)
1230 @frame_base.DeferredFrame._register_for(pd.Series)
-> 1231 class DeferredSeries(DeferredDataFrameOrSeries):
1232 def __repr__(self):
1233 return (
1234 f'DeferredSeries(name={self.name!r}, dtype={self.dtype}, '
1235 f'{self._render_indexes()})')
File ~/miniconda3/envs/runner/lib/python3.9/site-packages/apache_beam/dataframe/frames.py:1339, in DeferredSeries()
1331 transpose = frame_base._elementwise_method('transpose', base=pd.Series)
1332 shape = property(
1333 frame_base.wont_implement_method(
1334 pd.Series, 'shape', reason="non-deferred-result"))
1336 @frame_base.with_docs_from(pd.Series)
1337 @frame_base.args_to_kwargs(pd.Series)
1338 @frame_base.populate_defaults(pd.Series)
-> 1339 def append(self, to_append, ignore_index, verify_integrity, **kwargs):
1340 """``ignore_index=True`` is not supported, because it requires generating an
1341 order-sensitive index."""
1342 if not isinstance(to_append, DeferredSeries):
File ~/miniconda3/envs/runner/lib/python3.9/site-packages/apache_beam/dataframe/frame_base.py:600, in populate_defaults.<locals>.wrap(func)
599 def wrap(func):
--> 600 base_argspec = getfullargspec(unwrap(getattr(base_type, func.__name__)))
601 if not base_argspec.defaults:
602 return func
AttributeError: type object 'Series' has no attribute 'append'