Skip to content

Commit

Permalink
reorder fields
Browse files Browse the repository at this point in the history
  • Loading branch information
haiqi96 committed Jun 12, 2024
1 parent daf6ce2 commit 77735d9
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -160,9 +160,9 @@ async def worker_connection_handler(reader: asyncio.StreamReader, writer: asynci
return
unpacker.feed(buf)

# Print out any messages we can decode
# Print out any messages we can decode in the form of ORIG_PATH: MSG
for unpacked in unpacker:
print(f"{unpacked[0]}: {unpacked[2]}", end="")
print(f"{unpacked[2]}: {unpacked[1]}", end="")
except asyncio.CancelledError:
return
finally:
Expand Down
4 changes: 2 additions & 2 deletions components/core/src/clp/clo/OutputHandler.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -30,10 +30,10 @@ ErrorCode NetworkOutputHandler::add_result(
Message const& encoded_message,
string_view decompressed_message
) {
msgpack::type::tuple<string, epochtime_t, string, string, uint64_t> src(
orig_file_path,
msgpack::type::tuple<epochtime_t, string, string, string, uint64_t> src(
encoded_message.get_ts_in_milli(),
decompressed_message,
orig_file_path,
orig_file_id,
encoded_message.get_log_event_ix()
);
Expand Down

0 comments on commit 77735d9

Please sign in to comment.