Adds base.Command.run_from_argv

celery/bin/base.py

@@ -174,6 +174,9 @@ class Command(object):
         prog_name = os.path.basename(argv[0])
         return self.handle_argv(prog_name, argv[1:])
 
+    def run_from_argv(self, prog_name, argv=None):
+        return self.handle_argv(prog_name, sys.argv if argv is None else argv)
+
     def maybe_patch_concurrency(self, argv=None):
         argv = argv or sys.argv
         pool_option = self.with_pool_option(argv)