Source code for datacatalog.linkedstores.pipeline.schema
from ..basestore import HeritableDocumentSchema
from ..basestore import msec_precision
[docs]class PipelineDocument(HeritableDocumentSchema):
"""Defines a compute or ETL pipeline"""
def __init__(self, inheritance=True, **kwargs):
super(PipelineDocument, self).__init__(inheritance, **kwargs)
self.update_id()