diff --git a/luigi/rpc.py b/luigi/rpc.py
index 2066cbbc62..6a8030d8f2 100644
--- a/luigi/rpc.py
+++ b/luigi/rpc.py
@@ -145,7 +145,7 @@ def __init__(self, url='http://localhost:8082/', connect_timeout=None):
             'You need to install requests-unixsocket for Unix socket support.'
         )
 
-        self._url = url.rstrip('/')
+        self._url =  url if url[-1] == '/' else url + '/'
         config = configuration.get_config()
 
         if connect_timeout is None:
diff --git a/luigi/scheduler.py b/luigi/scheduler.py
index 10d67a10af..f9bbc5f722 100644
--- a/luigi/scheduler.py
+++ b/luigi/scheduler.py
@@ -111,7 +111,7 @@ def rpc_func(self, *args, **kwargs):
             if not all(arg in actual_args for arg in required_args):
                 raise TypeError('{} takes {} arguments ({} given)'.format(
                     fn_name, len(all_args), len(actual_args)))
-            return self._request('/api/{}'.format(fn_name), actual_args, **request_args)
+            return self._request('api/{}'.format(fn_name), actual_args, **request_args)
 
         RPC_METHODS[fn_name] = rpc_func
         return fn