mirror of https://github.com/D4-project/d4-core
fix: [worker 8] use binary type
parent
3162f44e36
commit
fca82b15b1
|
@ -92,7 +92,7 @@ if __name__ == "__main__":
|
|||
if id and data:
|
||||
# reconstruct data
|
||||
if buffer != b'':
|
||||
data[b'message'] = '{}{}'.format(buffer, data[b'message'])
|
||||
data[b'message'] = b'{}{}'.format(buffer, data[b'message'])
|
||||
buffer = b''
|
||||
|
||||
# send data to redis
|
||||
|
|
Loading…
Reference in New Issue