    ["-f" "--from DATE" "DATE from which on builds are loaded (by default tries to pick up where the last run finished)"
     :id :sync-start-time
     :parse-fn #(tf/parse date-formatter %)]
-   ["-s" "--aggregate PIPELINE" "PIPELINE for which a complete stage will be synced as a job"
-    :id :aggregate-jobs-for-pipelines
+   ["-j" "--sync-jobs PIPELINE" "PIPELINE for which Go jobs will be synced individually (not aggregated inside stage)"
+    :id :sync-jobs
     :default '()
     :assoc-fn (fn [previous key val] (assoc previous key (conj (get previous key) val)))]
    ["-h" "--help"]])

         (take-while #(t/after? (:scheduled-time %) safe-build-start-date)))))


(defn add-inputs-for-stage-instances [stage-instance]
  (let [pipeline-run (:pipelineRun stage-instance)
        pipeline-name (:pipelineName stage-instance)
        inputs (goapi/get-inputs-for-pipeline-run go-url pipeline-name pipeline-run)]

           :job-instances (list (assoc aggregated-build
                                       :junit-xml aggregated-junit-xml)))))

(defn- aggregate-jobs-for-stage-instance [stage-instance sync-jobs-for-pipelines]
  (let [{pipeline-name :pipelineName} stage-instance]
    (if (contains? sync-jobs-for-pipelines pipeline-name)
      stage-instance
      (aggregate-jobs-for-stage stage-instance))))


(defn- build-for-job [stage-instance job-name]
