mirror of https://github.com/D4-project/d4-core
fix: [worker 8] join
parent
4caa46a003
commit
10d29fff8c
|
@ -108,7 +108,7 @@ if __name__ == "__main__":
|
||||||
if id and data:
|
if id and data:
|
||||||
# reconstruct data
|
# reconstruct data
|
||||||
if buffer != b'':
|
if buffer != b'':
|
||||||
data[b'message'] = b''.join(buffer, data[b'message'])
|
data[b'message'] = b''.join([buffer, data[b'message']])
|
||||||
buffer = b''
|
buffer = b''
|
||||||
|
|
||||||
# send data to redis
|
# send data to redis
|
||||||
|
|
Loading…
Reference in New Issue