diff piecrust/pipelines/base.py @ 853:f070a4fc033c

core: Continue PieCrust3 refactor, simplify pages. The asset pipeline is still the only function pipeline at this point. * No more `QualifiedPage`, and several other pieces of code deleted. * Data providers are simpler and more focused. For instance, the page iterator doesn't try to support other types of items. * Route parameters are proper known source metadata to remove the confusion between the two. * Make the baker and pipeline more correctly manage records and record histories. * Add support for record collapsing and deleting stale outputs in the asset pipeline.
author Ludovic Chabant <ludovic@chabant.com>
date Sun, 21 May 2017 00:06:59 -0700
parents 4850f8c21b6e
children 08e02c2a2a1a
line wrap: on
line diff
--- a/piecrust/pipelines/base.py	Wed May 17 00:11:48 2017 -0700
+++ b/piecrust/pipelines/base.py	Sun May 21 00:06:59 2017 -0700
@@ -30,10 +30,17 @@
         """
         return self.worker_id < 0
 
+    @property
+    def current_record(self):
+        return self.record_history.current
+
 
 class PipelineResult:
-    def __init__(self, record):
-        self.record = record
+    """ Result of running a pipeline on a content item.
+    """
+    def __init__(self):
+        self.pipeline_name = None
+        self.record_entry = None
 
 
 class ContentPipeline:
@@ -41,7 +48,7 @@
     """
     PIPELINE_NAME = None
     PIPELINE_PASSES = 1
-    RECORD_CLASS = None
+    RECORD_ENTRY_CLASS = None
 
     def __init__(self, source):
         self.source = source
@@ -63,11 +70,11 @@
     def run(self, content_item, ctx, result):
         raise NotImplementedError()
 
-    def shutdown(self, ctx):
+    def getDeletions(self, ctx):
         pass
 
-    def collapseRecords(self, record_history):
+    def collapseRecords(self, ctx):
         pass
 
-    def getDeletions(self, record_history):
+    def shutdown(self, ctx):
         pass