diff --git a/framework/jobs/src/org/apache/cloudstack/framework/jobs/impl/AsyncJobMonitor.java b/framework/jobs/src/org/apache/cloudstack/framework/jobs/impl/AsyncJobMonitor.java
index cd106435df5..1042fac49da 100644
--- a/framework/jobs/src/org/apache/cloudstack/framework/jobs/impl/AsyncJobMonitor.java
+++ b/framework/jobs/src/org/apache/cloudstack/framework/jobs/impl/AsyncJobMonitor.java
@@ -111,7 +111,7 @@ public class AsyncJobMonitor extends ManagerBase {
 		synchronized(this) {
 			s_logger.info("Add job-" + jobId + " into job monitoring");
 			
-			assert(_activeTasks.get(jobId) == null);
+			assert(_activeTasks.get(runNumber) == null);
 			
 			long threadId = Thread.currentThread().getId();
 			boolean fromPoolThread = Thread.currentThread().getName().contains(AsyncJobConstants.JOB_POOL_THREAD_PREFIX);