search

aliyun / alibabacloud-odps-maxframe-client

Apache License 2.0
3 stars 1 forks source link

SDK: ValueError: Unpack failed: incomplete input #23

Closed ericpai closed 1 week ago

ericpai commented 1 week ago 
/root/miniconda/envs/py3.7/lib/python3.7/site-packages/maxframe/core/entity/tileables.py:434: in execute
    result = self.data.execute(session=session, **kw)
        kw         = {}
        self       = DataFrame 
        session    = None
/tmp/maxframe-e2e/maxframe_e2e/conftest.py:216: in _patched_execute
    return original_execute(*args, **kw)
        args       = (DataFrame ,)
        call_point = 'test_timestamp.py: 27'
        cur_frame  = 
        filename   = 'test_timestamp.py'
        kw         = {'session': None}
        maxframe_dag_properties = {'dags': [DagSubmitRecord(session_id='20240622154055264g9xbxsudzqm', dag_id='e7801631eee14797ae9d2af75d31a60f', start_time=None, end_time=None, call_point='test_timestamp.py: 27')]}
        original_execute = 
/root/miniconda/envs/py3.7/lib/python3.7/site-packages/maxframe/core/entity/executable.py:150: in execute
    return execute(self, session=session, **kw)
        execute    = 
        kw         = {}
        self       = DataFrame 
        session    = 
/root/miniconda/envs/py3.7/lib/python3.7/site-packages/maxframe/session.py:1061: in execute
    **kwargs,
        kwargs     = {}
        new_session_kwargs = None
        progress_update_interval = 1
        session    = 
        show_progress = None
        tileable   = DataFrame 
        tileables  = ()
        wait       = True
/root/miniconda/envs/py3.7/lib/python3.7/site-packages/maxframe/session.py:873: in execute
    timeout=self._isolated_session.timeout
        cancelled  = 
        coro       = 
        fut        = 
        kwargs     = {'cancelled': , 'progress_update_interval': 1, 'wait': True}
        result_future = 
        self       = 
        show_progress = False
        t          = DataFrame 
        tileable   = DataFrame 
        tileables  = ()
        to_execute_tileables = [DataFrame ]
        wait       = True
        warn_duplicated_execution = False
/root/miniconda/envs/py3.7/lib/python3.7/concurrent/futures/_base.py:435: in result
    return self.__get_result()
        self       = 
        timeout    = None
/root/miniconda/envs/py3.7/lib/python3.7/concurrent/futures/_base.py:384: in __get_result
    raise self._exception
        self       = 
/root/miniconda/envs/py3.7/lib/python3.7/site-packages/maxframe/utils.py:976: in cb
    dest.set_result(fut.result())
        dest       = 
        fut        = 
/root/miniconda/envs/py3.7/lib/python3.7/concurrent/futures/_base.py:428: in result
    return self.__get_result()
        self       = 
        timeout    = None
/root/miniconda/envs/py3.7/lib/python3.7/concurrent/futures/_base.py:384: in __get_result
    raise self._exception
        self       = 
/root/miniconda/envs/py3.7/lib/python3.7/site-packages/maxframe/session.py:1035: in _execute
    await execution_info
        _attach_session = ._attach_session at 0x7f0428dd6e60>
        cancel_task =  result=True>
        cancelled  = 
        exec_task  =  exception=ValueError('Unpack failed: incomplete input')>
        execution_info = 
        kwargs     = {'warn_duplicated_execution': False}
        progress_bar = 
        progress_update_interval = 1
        session    = 
        show_progress = False
        tileables  = (DataFrame ,)
        wait       = True
/root/miniconda/envs/py3.7/lib/python3.7/asyncio/tasks.py:630: in _wrap_awaitable
    return (yield from awaitable.__await__())
        awaitable  = 
/root/miniconda/envs/py3.7/lib/python3.7/site-packages/maxframe/session.py:75: in wait
    return await self._aio_task
        self       = 
/root/miniconda/envs/py3.7/lib/python3.7/site-packages/maxframe_client/session/odps.py:276: in _run_in_background
    self._caller.get_dag_info, dag_id
        dag_id     = 'e7801631eee14797ae9d2af75d31a60f'
        dag_info   = DagInfo(tileable_to_result_infos={}, end_timestamp=None, error_info=None, progress=0.0, status=, start_timestamp=None, dag_id='e7801631eee14797ae9d2af75d31a60f', session_id='20240622154055264g9xbxsudzqm')
        elapsed_time = 33.238919258117676
        key_to_tileables = {'e60c38917861af28c08ec940fb3d4824_0': DataFrame }
        progress   = Progress(value=0.0)
        self       = 
        start_time = 1719072239.5348098
        tileables  = [DataFrame ]
        timeout_val = 10
        wait_timeout = 10
/root/miniconda/envs/py3.7/lib/python3.7/site-packages/maxframe/utils.py:494: in to_thread
    return await asyncio.wait_for(asyncio.shield(task), timeout)
        args       = ('e7801631eee14797ae9d2af75d31a60f',)
        func       = >
        kwargs     = {}
        self       = 
        task       =  exception=ValueError('Unpack failed: incomplete input')>
        timeout    = None
        wait_on_cancel = False
/root/miniconda/envs/py3.7/lib/python3.7/asyncio/tasks.py:414: in wait_for
    return await fut
        fut        = 
        loop       = <_UnixSelectorEventLoop running=True closed=False debug=False>
        timeout    = None
/root/miniconda/envs/py3.7/lib/python3.7/site-packages/maxframe/utils.py:449: in to_thread_pool
    return await loop.run_in_executor(pool, func_call)
        args       = ('e7801631eee14797ae9d2af75d31a60f',)
        ctx        = 
        func       = >
        func_call  = functools.partial(, >, 'e7801631eee14797ae9d2af75d31a60f')
        kwargs     = {}
        loop       = <_UnixSelectorEventLoop running=True closed=False debug=False>
        pool       = 
/root/miniconda/envs/py3.7/lib/python3.7/concurrent/futures/thread.py:57: in run
    result = self.fn(*self.args, **self.kwargs)
        self       = None
/root/miniconda/envs/py3.7/lib/python3.7/site-packages/maxframe_client/session/task.py:260: in get_dag_info
    return self._deserial_task_info_result(res, DagInfo)
        dag_id     = 'e7801631eee14797ae9d2af75d31a60f'
        req_data   = {'dag_id': 'e7801631eee14797ae9d2af75d31a60f', 'output_format': 'msgpack', 'protocol': 'v1'}
        res        = '{\n    "result": "",\n    "status": "ok"}'
        self       = 
/root/miniconda/envs/py3.7/lib/python3.7/site-packages/maxframe_client/session/task.py:156: in _deserial_task_info_result
    return target_cls.from_json(msgpack.loads(result_data))
        content    = '{\n    "result": "",\n    "status": "ok"}'
        json_data  = {'result': '', 'status': 'ok'}
        result_data = b''
        self       = 
        target_cls = 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

>   ???
E   ValueError: Unpack failed: incomplete input

BufferFull = 
ExtraData  = 
FormatError = 
OutOfData  = 
Packer     = 
StackError = 
Unpacker   = 
__builtins__ = 
__doc__    = None
__file__   = '/root/miniconda/envs/py3.7/lib/python3.7/site-packages/msgpack/_cmsgpack.cpython-37m-x86_64-linux-gnu.so'
__loader__ = <_frozen_importlib_external.ExtensionFileLoader object at 0x7f050cc3af90>
__name__   = 'msgpack._cmsgpack'
__package__ = 'msgpack'
__spec__   = ModuleSpec(name='msgpack._cmsgpack', loader=<_frozen_importlib_external.ExtensionFileLoader object at 0x7f050cc3af90>, origin='/root/miniconda/envs/py3.7/lib/python3.7/site-packages/msgpack/_cmsgpack.cpython-37m-x86_64-linux-gnu.so')
__test__   = {}
datetime   = 
default_read_extended_type = 
unpackb    = 

msgpack/_unpacker.pyx:205: ValueError
ericpai commented 1 week ago

Fixed in v1.0.0