@@ -769,11 +769,11 @@
         (hash-table-set! smallest-last-update-time "smallest-time" last-update)))
 		(pgdb:refresh-run-info
 		 dbh
 		 new-run-id
 		 state status owner event-time comment fail-count pass-count area-id last-update publish-time)
-     (debug:print-info 4 *default-log-port* "Working on run-id " run-id " pgdb-id "  new-run-id )
+     (debug:print-info 4 *default-log-port* (conc "Working on run-id " run-id " pgdb-id "  new-run-id))
      (if (not (equal? run-tag ""))
       (task:add-run-tag dbh new-run-id run-tag))
 		new-run-id) 
       
 	      (if (or (not state) (equal? state "deleted"))
@@ -927,17 +927,17 @@
       (debug:print-info 1 *default-log-port*  "Error: Could not get test data info for data id " test-data-id ))))	;; this is a wierd senario need to debug      	
    test-data-ids)))
 
 
 
-(define (tasks:sync-tests-data dbh cached-info test-ids area-info smallest-last-update-time)
+(define (tasks:sync-tests-data dbh cached-info test-ids area-info smallest-last-update-time main-run-id)
   (let ((test-ht (hash-table-ref cached-info 'tests))
-        (run-id-in #f))
+        (run-id-in main-run-id))
     (for-each
      (lambda (test-id)
-        (set! run-id-in  (cdr test-id))
-        (set! test-id (car test-id))
+       ; (set! run-id-in  (cdr test-id))
+       ; (set! test-id (car test-id))
 
         (debug:print 0 *default-log-port*  "test-id: " test-id " run-id: " run-id-in) 
        (let* ((test-info    (rmt:get-test-info-by-id run-id-in test-id))
 	      (run-id       (db:test-get-run_id    test-info)) ;; look these up in db_records.scm
 	      (test-id      (db:test-get-id        test-info))
@@ -1014,11 +1014,10 @@
      (lambda (run-id)
       (debug:print-info 4 *default-log-port*   "Check if run with " run-id " needs to be synced" )
        (tasks:run-id->mtpg-run-id dbh cached-info run-id area-info smallest-last-update-time))
 run-ids))
 
-
 ;; get runs changed since last sync
 ;; (define (tasks:sync-test-data dbh cached-info area-info)
 ;;   (let* ((
 
 (define (tasks:sync-to-postgres configdat dest)
@@ -1049,39 +1048,43 @@
     (for-each (lambda (dtype)
 		(hash-table-set! cached-info dtype (make-hash-table)))
 	      '(runs targets tests steps data))
     (hash-table-set! cached-info 'start start) ;; when done we'll set sync times to this
     (if area-info
-	(let* ((last-sync-time (if (args:get-arg "-since") (string->number (args:get-arg "-since")) (vector-ref area-info 3)))
+	(let* ((last-sync-time (if (and target run-name)
+                                 0
+                                 (if (args:get-arg "-since") 
+                                   (string->number (args:get-arg "-since")) (vector-ref area-info 3))))
 	       (smallest-last-update-time  (make-hash-table))
-               (changed      (if (and target run-name)
-                            (rmt:get-run-record-ids target run-name (rmt:get-keys) test-patt)
-                            (rmt:get-changed-record-ids last-sync-time)))
-	       (run-ids        (alist-ref 'runs       changed))
-	       (test-ids       (alist-ref 'tests      changed))
+               (run-ids       (if (and target run-name)
+                                   (rmt:get-run-record-ids target run-name (rmt:get-keys)) 
+                                   (rmt:get-changed-record-run-ids last-sync-time)))
+               (all-run-ids   (if (and target run-name) '() (rmt:get-all-runids)))
+               (changed-run-dbs (if (and target run-name) '() (db:get-changed-run-ids last-sync-time)))
+               (changed-run-ids (if (and target run-name) run-ids (filter (lambda (run) (member (modulo run 100) changed-run-dbs)) all-run-ids)))
                (area-tag    (if (args:get-arg "-area-tag") 
                                  (args:get-arg "-area-tag")
                                  (if (args:get-arg "-area") 
                                    (args:get-arg "-area") 
                                    ""))))
            (if (and (equal? area-tag "") (not (pgdb:is-area-taged dbh (vector-ref area-info 0))))
             (set! area-tag *default-area-tag*)) 
            (if (not (equal? area-tag "")) 
-             (task:add-area-tag dbh area-info area-tag)) 
-          (if (not (null? run-ids))
+             (task:add-area-tag dbh area-info area-tag))
+           (if (not (null? run-ids))
             (begin
                (debug:print-info 0 *default-log-port*  "syncing runs: " run-ids)   
-	       (tasks:sync-run-data dbh cached-info run-ids area-info smallest-last-update-time) 
-            )
-          )
-          (if (not (null? test-ids))
-            (begin
-              (debug:print-info 0 *default-log-port*  "syncing tests: " test-ids)
-	      (tasks:sync-tests-data dbh cached-info test-ids area-info smallest-last-update-time)
-              (debug:print-info 0 *default-log-port*  "syncing test steps")
-            )
-          )
+	       (tasks:sync-run-data dbh cached-info run-ids area-info smallest-last-update-time)))
+          (for-each
+            (lambda (run-id)
+              (let ((test-ids (rmt:get-changed-record-test-ids run-id  last-sync-time)))
+              (print test-ids)
+              (if (not (null? test-ids))
+              (begin
+                (debug:print-info 0 *default-log-port*  "syncing tests: " test-ids)
+	        (tasks:sync-tests-data dbh cached-info test-ids area-info smallest-last-update-time run-id)))))
+            changed-run-ids)
      (let*  ((smallest-time (hash-table-ref/default smallest-last-update-time "smallest-time" (current-seconds))))
      (debug:print-info 0 "smallest-time :" smallest-time  " last-sync-time " last-sync-time)
     (if (not (and target run-name)) 
 	  (if (or (and smallest-time (> smallest-time last-sync-time)) (and smallest-time (eq? last-sync-time 0)))
 				(pgdb:write-sync-time dbh area-info smallest-time))))) ;;this needs to be changed