Skip to content

Commit 22402b3

Browse files
committed
Updated xray sdk version
1 parent 8d76dba commit 22402b3

File tree

3 files changed

+9
-8
lines changed

3 files changed

+9
-8
lines changed

lib/idp_common_pkg/pyproject.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -101,7 +101,7 @@ agents = [
101101
# This includes all dependencies needed for both backends
102102
docs_service = [
103103
"requests==2.32.4", # Required for appsync module (dynamodb only needs boto3 which is core)
104-
"aws-xray-sdk>=2.12.0", # Required for X-Ray tracing
104+
"aws-xray-sdk>=2.14.0", # Required for X-Ray tracing
105105
]
106106

107107
# Testing dependencies

lib/idp_common_pkg/setup.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@
6161
# Document service factory dependencies (includes both appsync and dynamodb support)
6262
"docs_service": [
6363
"requests==2.32.4",
64-
"aws-xray-sdk>=2.12.0",
64+
"aws-xray-sdk>=2.14.0",
6565
],
6666
# Testing dependencies
6767
"test": [

src/lambda/queue_processor/index.py

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -142,12 +142,13 @@ def process_message(record: Dict[str, Any]) -> Tuple[bool, str]:
142142
object_key = document.input_key
143143
logger.info(f"Processing message {message_id} for object {object_key}")
144144

145-
# Add X-Ray annotations and capture trace_id early
146-
xray_recorder.put_annotation('document_id', document.id)
147-
current_segment = xray_recorder.current_segment()
148-
if current_segment:
149-
document.trace_id = current_segment.trace_id
150-
logger.info(f"Updated {document.id} trace_id: {document.trace_id}")
145+
# X-Ray annotations
146+
xray_recorder.put_annotation('document_id', {document.id})
147+
xray_recorder.put_annotation('processing_stage', 'queue_processor')
148+
# current_segment = xray_recorder.current_segment()
149+
# if current_segment:
150+
# document.trace_id = current_segment.trace_id
151+
# logger.info(f"Updated {document.id} trace_id: {document.trace_id}")
151152

152153
# Try to increment counter
153154
if not update_counter(increment=True):

0 commit comments

Comments
 (0)