diff --git a/app/org/thp/cortex/controllers/JobCtrl.scala b/app/org/thp/cortex/controllers/JobCtrl.scala
index 7dc42eac3..70c4abcf5 100644
--- a/app/org/thp/cortex/controllers/JobCtrl.scala
+++ b/app/org/thp/cortex/controllers/JobCtrl.scala
@@ -35,8 +35,8 @@ class JobCtrl @Inject() (
     implicit val mat: Materializer,
     implicit val actorSystem: ActorSystem) extends AbstractController(components) with Status {
 
-  def list(dataTypeFilter: Option[String], dataFilter: Option[String], analyzerFilter: Option[String], range: Option[String]): Action[AnyContent] = authenticated(Roles.read).async { implicit request ⇒
-    val (jobs, jobTotal) = jobSrv.listForUser(request.userId, dataTypeFilter, dataFilter, analyzerFilter, range)
+  def list(dataTypeFilter: Option[String], dataFilter: Option[String], workerFilter: Option[String], range: Option[String]): Action[AnyContent] = authenticated(Roles.read).async { implicit request ⇒
+    val (jobs, jobTotal) = jobSrv.listForUser(request.userId, dataTypeFilter, dataFilter, workerFilter, range)
     renderer.toOutput(OK, jobs, jobTotal)
   }
 
diff --git a/app/org/thp/cortex/services/JobSrv.scala b/app/org/thp/cortex/services/JobSrv.scala
index dd630eb95..de7c2c2ff 100644
--- a/app/org/thp/cortex/services/JobSrv.scala
+++ b/app/org/thp/cortex/services/JobSrv.scala
@@ -187,8 +187,8 @@ class JobSrv(
         })
   }
 
-  def create(analyzerId: String, fields: Fields)(implicit authContext: AuthContext): Future[Job] = {
-    workerSrv.getForUser(authContext.userId, analyzerId).flatMap { worker ⇒
+  def create(workerId: String, fields: Fields)(implicit authContext: AuthContext): Future[Job] = {
+    workerSrv.getForUser(authContext.userId, workerId).flatMap { worker ⇒
       /*
       In Cortex 1, fields looks like:
       {
@@ -257,9 +257,9 @@ class JobSrv(
       case None ⇒ isUnderRateLimit(worker).flatMap {
         case true ⇒
           val fields = Fields(Json.obj(
-            "analyzerDefinitionId" -> worker.workerDefinitionId(),
-            "analyzerId" -> worker.id,
-            "analyzerName" -> worker.name(),
+            "workerDefinitionId" -> worker.workerDefinitionId(),
+            "workerId" -> worker.id,
+            "workerName" -> worker.name(),
             "organization" -> worker.parentId,
             "status" -> JobStatus.Waiting,
             "dataType" -> dataType,