Changeset 9718 for main

Timestamp:

24 Nov 2012, 17:19:04 (12 years ago)

Author:

uli

Message:

Support additional args for export jobs. These changes do not break existing instances.

Location:

main/waeup.kofa/trunk/src/waeup/kofa

Files:

• interfaces.py (modified) (2 diffs)
• utils/batching.py (modified) (3 diffs)

main/waeup.kofa/trunk/src/waeup/kofa/interfaces.py

@@ -1164 +1164 @@
     """A component that contains (maybe virtually) export jobs.
     """
-    def start_export_job(exporter_name, user_id):
+    def start_export_job(exporter_name, user_id, *args, **kwargs):
         """Start asynchronous export job.
 
@@ -1170 +1170 @@
 
         `user_id` is the ID of the user that triggers the export.
+
+        `args` positional arguments passed to the export job created.
+
+        `kwargs` keyword arguments passed to the export job.
 
         The job_id is stored along with exporter name and user id in a

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

@@ -560 +560 @@
     grok.implements(IExportJob)
 
-    def __init__(self, site, exporter_name):
+    def __init__(self, site, exporter_name, *args, **kwargs):
         super(AsyncExportJob, self).__init__(
-            export_job, site, exporter_name)
+            export_job, site, exporter_name, *args, **kwargs)
 
 class ExportJobContainer(object):
@@ -570 +570 @@
     running_exports = PersistentList()
 
-    def start_export_job(self, exporter_name, user_id):
+    def start_export_job(self, exporter_name, user_id, *args, **kwargs):
         """Start asynchronous export job.
 
@@ -580 +580 @@
         persistent list.
 
+        The method supports additional positional and keyword
+        arguments, which are passed as-is to the respective
+        :class:`AsyncExportJob`.
+
         Returns the job ID of the job started.
         """
         site = grok.getSite()
         manager = getUtility(IJobManager)
-        job = AsyncExportJob(site, exporter_name)
+        job = AsyncExportJob(site, exporter_name, *args, **kwargs)
         job_id = manager.put(job)
         # Make sure that the persisted list is stored in ZODB