Skip to content

Projections reader using core reader #142

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 12 commits into
base: develop
Choose a base branch
from
Open

Projections reader using core reader #142

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
12 commits
Select commit Hold shift + click to select a range
cb55f9e
initial draft of base reader
Sep 27, 2024
8d7d9e2
updates to base reader
Sep 30, 2024
ceae939
base reader working without cct creation
Oct 3, 2024
8f7880a
Base Reader for single threaded reading
Oct 13, 2024
65e4332
changes to make core reader more parallel-friendly
Oct 13, 2024
2195cff
minor updates to remove re-reading of sts file
Oct 13, 2024
dac0b9c
updates to have strided unique_id, take care of instant events, and t…
Oct 14, 2024
635cd2d
updates to use core reader
Oct 14, 2024
3daf5b9
removed unneeded function
Oct 14, 2024
99ed8b9
Merge branch 'develop' into projections-core-reader
lithomas1 Feb 19, 2025
964a9b7
cleanup
lithomas1 Feb 19, 2025
ad6349f
lint
lithomas1 Feb 19, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 5 additions & 4 deletions pipit/readers/core_reader.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
from typing import List, Dict

import pandas
import numpy as np
from pipit.trace import Trace


Expand Down Expand Up @@ -102,9 +103,9 @@ def finalize(self):
"Name": "category",
"Event Type": "category",
"Process": "category",
"_matching_event": "int32",
"_parent": "int32",
"_matching_timestamp": "int32",
"_matching_event": "Int32",
"_parent": "Int32",
"_matching_timestamp": "Int32",
}
)
return trace_df
Expand All @@ -118,7 +119,7 @@ def __update_parent_child_relationships(
"""
if len(stack) == 0:
# root event
event["_parent"] = -1
event["_parent"] = np.nan
else:
parent_event = event_list[stack[-1]]
event["_parent"] = parent_event["unique_id"]
Expand Down
Loading
Loading