ydf0509/funboost

status_and_result 和 get()都获取不到函数返回的结果

zxcvbn001 opened this issue · 2 comments

@task_deco(queue_name='test', broker_kind=BrokerEnum.REDIS, is_send_consumer_hearbeat_to_redis=True)
def test(a, b):
return a + b

test.consume()
async_result = test.push(1, 0)
print(async_result.status_and_result)

入参要设置is_using_rpc_mode = True

说得对,要is_using_rpc_mode = True。 rpc模式第一行就说了要设置true