Skip to content

Commit 3adc1ab

Browse files
author
Emanuele Palazzetti
authored
Merge pull request #469 from DataDog/alex.charrier/ddtracerun-celery
[celery] fixing ddtrace-run broke celery support
2 parents 75b7275 + 8f2ec26 commit 3adc1ab

File tree

5 files changed

+21
-0
lines changed

5 files changed

+21
-0
lines changed

ddtrace/bootstrap/sitecustomize.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -70,6 +70,9 @@ def update_patched_modules():
7070
if opts:
7171
tracer.configure(**opts)
7272

73+
if not hasattr(sys, 'argv'):
74+
sys.argv = ['']
75+
7376
if patch:
7477
update_patched_modules()
7578
from ddtrace import patch_all; patch_all(**EXTRA_PATCHED_MODULES) # noqa

tests/commands/ddtrace_run_argv.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
from __future__ import print_function
2+
3+
from ddtrace import tracer
4+
5+
from nose.tools import eq_
6+
import sys
7+
8+
if __name__ == '__main__':
9+
eq_(sys.argv[1:], ['foo', 'bar'])
10+
print("Test success")

tests/commands/ddtrace_run_patched_modules.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,4 +6,5 @@
66

77
if __name__ == '__main__':
88
ok_('redis' in monkey.get_patched_modules())
9+
ok_('celery' in monkey.get_patched_modules())
910
print("Test success")

tests/commands/test_runner.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -169,3 +169,9 @@ def test_sitecustomize_run_suppressed(self):
169169
env=env,
170170
)
171171
assert out.startswith(b"Test success")
172+
173+
def test_argv_passed(self):
174+
out = subprocess.check_output(
175+
['ddtrace-run', 'python', 'tests/commands/ddtrace_run_argv.py', 'foo', 'bar']
176+
)
177+
assert out.startswith(b"Test success")

tox.ini

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -131,6 +131,7 @@ deps =
131131
# TODO[manu] update to a stable version of Celery
132132
celery42: celery==4.2.0rc3
133133
ddtracerun: redis
134+
ddtracerun: celery
134135
elasticsearch16: elasticsearch>=1.6,<1.7
135136
elasticsearch17: elasticsearch>=1.7,<1.8
136137
elasticsearch18: elasticsearch>=1.8,<1.9

0 commit comments

Comments
 (0)