status_and_result 和 get()都获取不到函数返回的结果
zxcvbn001 opened this issue · 2 comments
zxcvbn001 commented
@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)
hguitar commented
入参要设置is_using_rpc_mode = True
ydf0509 commented
说得对,要is_using_rpc_mode = True。 rpc模式第一行就说了要设置true