Update hdfs_jobs.jl

Update delete! usage in response to JuliaLang/julia#3439
JuliaPackageMirrors · Aug 14, 2013 · 7eb8f9f · 7eb8f9f
1 parent 58ffd49
commit 7eb8f9f
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/hdfs_jobs.jl b/src/hdfs_jobs.jl
@@ -1,4 +1,3 @@
-
 ##
 # Assign Job Ids. A one up number
 global __next_job_id = int64(0)::JobId
@@ -71,7 +70,9 @@ end
 
 function _worker_task(t::WorkerTaskUnloadJob)
     d = ((myid() == 1) ? _def_wrkr_job_store : _job_store)
-    j = delete!(d, t.jid)
+    # After v0.2: j = pop!(d, t.jid)
+    j = d[t.jid]
+    delete!(d, t.jid)
     isa(j.info, HdfsJobRunInfo) && isa(j.info.rdr, MapStreamInputReader) && close(j.info.rdr)
     t.jid
 end