Changeset 4891 for waeup/trunk/src

Timestamp:

25 Jan 2010, 08:31:22 (15 years ago)

Author:

uli

Message:

Create a 'finished' file of successful items with batch operations.

File:

• waeup/trunk/src/waeup/utils/batching.py (modified) (2 diffs)

waeup/trunk/src/waeup/utils/batching.py

@@ -241 +241 @@
                                        failed_headers)
         failed_writer.writerow(dict([(x,x) for x in failed_headers]))
+
+        finished_path = "%s.%s.finished%s" % (base, mode, ext)
+        finished_headers = [x for x in mapping.values()]
+        finished_writer = csv.DictWriter(open(finished_path, 'wb'),
+                                         finished_headers)
+        finished_writer.writerow(dict([(x,x) for x in finished_headers]))
         
         num =0
@@ -289 +295 @@
                     continue
                 self.updateEntry(obj, row, site)
+            finished_writer.writerow(string_row)
 
         time_end = time.time()
         timedelta = time_end - time_start
         
-        if path.endswith('.pending'):
+        if path.endswith('.pending.csv'):
             os.unlink(path)
             os.rename(failed_path, path)