We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0e5853b commit 6eeea5eCopy full SHA for 6eeea5e
tests/opentelemetry-docker-tests/tests/celery/test_celery_functional.py
@@ -16,6 +16,7 @@
16
import celery
17
from celery.exceptions import Retry
18
from pytest import mark
19
+from time import sleep
20
21
import opentelemetry.instrumentation.celery
22
from opentelemetry import trace as trace_api
@@ -33,13 +34,13 @@ class MyException(Exception):
33
34
pass
35
36
-@mark.skip(reason="inconsistent test results")
37
def test_instrumentation_info(celery_app, memory_exporter):
38
@celery_app.task
39
def fn_task():
40
return 42
41
42
result = fn_task.apply_async()
43
+ sleep(1)
44
assert result.get(timeout=ASYNC_GET_TIMEOUT) == 42
45
46
spans = memory_exporter.get_finished_spans()
0 commit comments