Bladeren bron

Add test coverage for get_task_name() in PR #4379 (#4397)

* Add test coverage for get_task_name() in PR #4379 

Add test coverage for get_task_name() in PR #4379

* Added import for the function to be tested.
hclihn 7 jaren geleden
bovenliggende
commit
f51204f13a
1 gewijzigde bestanden met toevoegingen van 8 en 0 verwijderingen
  1. 8 0
      t/unit/tasks/test_trace.py

+ 8 - 0
t/unit/tasks/test_trace.py

@@ -5,11 +5,13 @@ from kombu.exceptions import EncodeError
 from celery import group, uuid
 from celery import signals
 from celery import states
+from celery.app.task import Context
 from celery.exceptions import Ignore, Retry, Reject
 from celery.app.trace import (
     TraceInfo,
     build_tracer,
     get_log_policy,
+    get_task_name,
     log_policy_reject,
     log_policy_ignore,
     log_policy_internal,
@@ -85,6 +87,12 @@ class test_trace(TraceCase):
         einfo2.internal = True
         assert (get_log_policy(self.add, einfo2, KeyError()) is
                 log_policy_internal)
+        
+    def test_get_task_name(self):
+        assert get_task_name(Context({}), 'default') == 'default'
+        assert get_task_name(Context({'shadow': None}), 'default') == 'default'
+        assert get_task_name(Context({'shadow': ''}), 'default') == 'default'
+        assert get_task_name(Context({'shadow': 'test'}), 'default') == 'test'
 
     def test_trace_after_return(self):