diff --git a/CHANGELOG.rst b/CHANGELOG.rst
index 5122016484f86208b933938238f9148ea3f80be2..7a4ecf4ebe1af6e37ce337f7a822f842c5da2c96 100644
--- a/CHANGELOG.rst
+++ b/CHANGELOG.rst
@@ -23,8 +23,11 @@ Changed
 
 * The :func:`.gifti.relatedFiles` function now supports files with
   BIDS-style naming conventions.
-* The :func:`.run.run` and :func:`.run.runfsl` functions now pass through
-  any additional keyword arguments to ``subprocess.Popen``.
+* The :func:`.run.run` and :func:`.run.runfsl` functions now pass through any
+  additional keyword arguments to ``subprocess.Popen`` or, if ``submit=True``,
+  to :func:`fslsub.submit`.
+* The :func:`.fslsub.submit` function now accepts an ``env`` option, allowing
+  environment variables to be specified.
 * The :func:`.run.runfsl` function now raises an error on attempts to
   run a command which is not present in ``$FSLDIR/bin/`` (e.g. ``ls``).
 * The :mod:`.bids` module has been updated to support files with any
diff --git a/fsl/utils/fslsub.py b/fsl/utils/fslsub.py
index 46bc0466ddb7c767491ffe3ab99ed369e6e25b2f..eb8bf971ce81cb40b007246408124d8fcac60465 100644
--- a/fsl/utils/fslsub.py
+++ b/fsl/utils/fslsub.py
@@ -68,7 +68,8 @@ def submit(*command,
            output=None,
            flags=False,
            multi_threaded=None,
-           verbose=False):
+           verbose=False,
+           env=None):
     """
     Submits a given command to the cluster
 
@@ -99,6 +100,7 @@ def submit(*command,
                           - <threads>: number of threads to run
 
     :arg verbose:        If True, use verbose mode
+    :arg env:            Dict containing environment variables
 
     :return:             string of submitted job id
     """
@@ -136,7 +138,7 @@ def submit(*command,
 
     base_cmd.extend(prepareArgs(command))
 
-    return runfsl(*base_cmd).strip()
+    return runfsl(*base_cmd, env=env).strip()
 
 
 def info(job_id):
diff --git a/fsl/utils/run.py b/fsl/utils/run.py
index 7211965d773f03d6c3abd583e3a4776bebaf7c2c..70915cf2dea6d0adcc68cd733283382c634153d1 100644
--- a/fsl/utils/run.py
+++ b/fsl/utils/run.py
@@ -168,7 +168,7 @@ def run(*args, **kwargs):
 
     All other keyword arguments are passed through to the ``subprocess.Popen``
     object (via :func:`_realrun`), unless ``submit=True``, in which case they
-    are ignored.
+    are passed through to the :func:`.fslsub.submit` function.
 
     :returns:      If ``submit`` is provided, the return value of
                    :func:`.fslsub` is returned. Otherwise returns a single
@@ -208,7 +208,7 @@ def run(*args, **kwargs):
 
     # submit - delegate to fslsub
     if submit is not None:
-        return fslsub.submit(' '.join(args), **submit)
+        return fslsub.submit(' '.join(args), **submit, **kwargs)
 
     # Run directly - delegate to _realrun
     stdout, stderr, exitcode = _realrun(
diff --git a/tests/test_run.py b/tests/test_run.py
index be9e443ca5d6b6da98b3bbf6187eff339d5c11b8..363d4489ec30d25799e152f23e96becf12f06ab9 100644
--- a/tests/test_run.py
+++ b/tests/test_run.py
@@ -306,29 +306,33 @@ def test_run_submit():
         mkexec(op.expandvars('$FSLDIR/bin/fsltest'), test_script)
 
         jid = run.run('fsltest', submit=True)
-
         assert jid == '12345'
-
         stdout, stderr = fslsub.output(jid)
-
         assert stdout == 'test_script running\n'
         assert stderr == ''
 
+        # or can pass submit opts as a dict
         kwargs = {'name' : 'abcde', 'ram' : '4GB'}
-
         jid = run.run('fsltest', submit=kwargs)
-
         assert jid == '12345'
-
         stdout, stderr = fslsub.output(jid)
-
         experr = '\n'.join(['{}: {}'.format(k, kwargs[k])
                             for k in sorted(kwargs.keys())]) + '\n'
+        assert stdout == 'test_script running\n'
+        assert stderr == experr
 
+        # or can pass submit opts as kwargs
+        kwargs = {'name' : 'abcde', 'ram' : '4GB'}
+        jid = run.run('fsltest', submit=True, **kwargs)
+        assert jid == '12345'
+        stdout, stderr = fslsub.output(jid)
+        experr = '\n'.join(['{}: {}'.format(k, kwargs[k])
+                            for k in sorted(kwargs.keys())]) + '\n'
         assert stdout == 'test_script running\n'
         assert stderr == experr
 
 
+
 def test_run_streams():
     """
     """