diff --git a/lib/Download.php b/lib/Download.php index 8aa08a9..71f36d6 100644 --- a/lib/Download.php +++ b/lib/Download.php @@ -20,9 +20,10 @@ class Download { { $db = DbMongo::get(); $coll = $db->download; - $dbRet = $coll->findOne( - ['cstate' => 'added'] - ); + $dbRet = $coll->findOne([ + 'cstate' => 'added', + 'worker' => getenv('WORKER') + ]); $myDownload = new Download(); $myDownload->db2Inst($dbRet);