Skip to content

Commit d453034

Browse files
saartochner-lumigoCircleCI
andauthored
change legit error to info & don't include end_time in HTTP requests before request finished (#240)
* change legit error to info * started request that haven't finished shouldn't have ended time Co-authored-by: CircleCI <[email protected]>
1 parent 92c8935 commit d453034

File tree

3 files changed

+12
-3
lines changed

3 files changed

+12
-3
lines changed

src/lumigo_tracer/lumigo_utils.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -373,7 +373,7 @@ def report_json(
373373
internal_analytics_message("report: socket.timeout")
374374
except Exception as e:
375375
if should_retry:
376-
get_logger().exception(f"Could not report to {host}. Retrying.", exc_info=e)
376+
get_logger().info(f"Could not report to {host}. Retrying.", exc_info=e)
377377
edge_connection = establish_connection(host)
378378
report_json(region, msgs, should_retry=False)
379379
else:

src/lumigo_tracer/spans_container.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -190,9 +190,9 @@ def update_event_times(
190190
"""
191191
if span_id in self.spans:
192192
start_timestamp = start_time.timestamp() if start_time else time.time()
193-
end_timestamp = end_time.timestamp() if end_time else time.time()
194193
self.spans[span_id]["started"] = int(start_timestamp * 1000)
195-
self.spans[span_id]["ended"] = int(end_timestamp * 1000)
194+
if end_time:
195+
self.spans[span_id]["ended"] = end_time.timestamp()
196196
else:
197197
get_logger().warning(f"update_event_times: Got unknown span id: {span_id}")
198198

src/test/unit/test_spans_container.py

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -247,3 +247,12 @@ def test_malformed_txid(monkeypatch, context):
247247
result = SpansContainer.get_span().get_patched_root()
248248
output_trace_id = result.split(";")[0].split("=")[1].split("-")[2]
249249
assert output_trace_id == SpansContainer.get_span().transaction_id
250+
251+
252+
def test_unfinished_request():
253+
container = SpansContainer.get_span()
254+
container.add_span({"id": "1", "extra": "a"})
255+
start = datetime(2022, 2, 21, 1, 1)
256+
container.update_event_times(span_id="1", start_time=start)
257+
assert container.get_span_by_id("1")["started"]
258+
assert "ended" not in container.get_span_by_id("1")

0 commit comments

Comments
 (0)