|
67 | 67 | from sentry.taskworker.retry import Retry |
68 | 68 | from sentry.utils import json, metrics |
69 | 69 | from sentry.utils.arroyo_producer import SingletonProducer, get_arroyo_producer |
| 70 | +from sentry.utils.eap import hex_to_item_id |
70 | 71 | from sentry.utils.kafka_config import get_topic_definition |
71 | 72 | from sentry.utils.locking import UnableToAcquireLock |
72 | 73 | from sentry.utils.outcomes import Outcome, track_outcome |
@@ -1725,7 +1726,7 @@ def build_chunk_functions_eap_trace_items( |
1725 | 1726 | organization_id=chunk.get_organization_id(), |
1726 | 1727 | project_id=chunk.get_project_id(), |
1727 | 1728 | trace_id=chunk.get_profiler_id(), # until we actually get a trace_id from the SDKs |
1728 | | - item_id=int(chunk.get_profiler_id(), 16).to_bytes(16, "little"), |
| 1729 | + item_id=hex_to_item_id(chunk.get_profiler_id()), |
1729 | 1730 | item_type=TraceItemType.TRACE_ITEM_TYPE_PROFILE_FUNCTION, |
1730 | 1731 | timestamp=_timestamp(chunk.start_timestamp()), |
1731 | 1732 | attributes=attributes, |
@@ -1801,7 +1802,7 @@ def build_profile_functions_eap_trace_items( |
1801 | 1802 | organization_id=profile.get_organization_id(), |
1802 | 1803 | project_id=profile.get_project_id(), |
1803 | 1804 | trace_id=profile.get_profile_id(), # until we actually get a trace_id from the SDKs |
1804 | | - item_id=int(profile.get_profile_id(), 16).to_bytes(16, "little"), |
| 1805 | + item_id=hex_to_item_id(profile.get_profile_id()), |
1805 | 1806 | item_type=TraceItemType.TRACE_ITEM_TYPE_PROFILE_FUNCTION, |
1806 | 1807 | timestamp=_timestamp(profile.get_timestamp()), |
1807 | 1808 | attributes=attributes, |
|
0 commit comments