Traceback (most recent call last):
File "/sample/.venv/lib/python3.12/site-packages/luigi/worker.py", line 210, in run
new_deps = self._run_get_new_deps()
^^^^^^^^^^^^^^^^^^^^^^^^
File "/sample/.venv/lib/python3.12/site-packages/luigi/worker.py", line 138, in _run_get_new_deps
task_gen = self.task.run()
^^^^^^^^^^^^^^^
File "/sample/.venv/lib/python3.12/site-packages/gokart/task_complete_check.py", line 16, in wrapper
return run_func(*args, **kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^
File "/sample/m3cosmos/data/preprocess_highlight_data.py", line 85, in run
self.dump(data.pipe(DataFrame[M3comActionsForCosmosSchema]))
File "/sample/.venv/lib/python3.12/site-packages/gokart/task.py", line 346, in dump
self._get_output_target(target).dump(
File "/sample/.venv/lib/python3.12/site-packages/gokart/target.py", line 44, in dump
wrap_dump_with_lock(func=self._dump, task_lock_params=self._get_task_lock_params(), exist_check=self.exists)(
File "/sample/.venv/lib/python3.12/site-packages/gokart/target.py", line 129, in _dump
GCSObjectMetadataClient.add_task_state_labels(
File "/sample/.venv/lib/python3.12/site-packages/gokart/gcs_obj_metadata_client.py", line 61, in add_task_state_labels
patched_metadata = GCSObjectMetadataClient._get_patched_obj_metadata(
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/sample/.venv/lib/python3.12/site-packages/gokart/gcs_obj_metadata_client.py", line 113, in _get_patched_obj_metadata
normalized_labels.append({'__required_task_outputs': json.dumps(GCSObjectMetadataClient._get_serialized_string(required_task_outputs))})
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/sample/.venv/lib/python3.12/site-packages/gokart/gcs_obj_metadata_client.py", line 128, in _get_serialized_string
return {k: GCSObjectMetadataClient._get_serialized_string(v) for k, v in required_task_outputs.items()}
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/sample/.venv/lib/python3.12/site-packages/gokart/gcs_obj_metadata_client.py", line 130, in _get_serialized_string
return list(_iterable_flatten([GCSObjectMetadataClient._get_serialized_string(ro) for ro in required_task_outputs]))
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/sample/.venv/lib/python3.12/site-packages/gokart/gcs_obj_metadata_client.py", line 130, in _get_serialized_string
return list(_iterable_flatten([GCSObjectMetadataClient._get_serialized_string(ro) for ro in required_task_outputs]))
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/sample/.venv/lib/python3.12/site-packages/gokart/gcs_obj_metadata_client.py", line 123, in _iterable_flatten
yield from _iterable_flatten(item)
File "/sample/.venv/lib/python3.12/site-packages/gokart/gcs_obj_metadata_client.py", line 123, in _iterable_flatten
yield from _iterable_flatten(item)
File "/sample/.venv/lib/python3.12/site-packages/gokart/gcs_obj_metadata_client.py", line 123, in _iterable_flatten
yield from _iterable_flatten(item)
[Previous line repeated 974 more times]
File "/sample/.venv/lib/python3.12/site-packages/gokart/gcs_obj_metadata_client.py", line 122, in _iterable_flatten
if isinstance(item, Iterable):
^^^^^^^^^^^^^^^^^^^^^^^^^^
RecursionError: maximum recursion depth exceeded
