diff --git a/PolicyGradient/a3c/train.py b/PolicyGradient/a3c/train.py
index 28064e506..286ca7a9d 100755
--- a/PolicyGradient/a3c/train.py
+++ b/PolicyGradient/a3c/train.py
@@ -125,7 +125,7 @@ def make_env(wrap=True):
   # Start worker threads
   worker_threads = []
   for worker in workers:
-    worker_fn = lambda: worker.run(sess, coord, FLAGS.t_max)
+    worker_fn = lambda worker=worker: worker.run(sess, coord, FLAGS.t_max)
     t = threading.Thread(target=worker_fn)
     t.start()
     worker_threads.append(t)