Source code for rdc.etl.harness.base

# -*- coding: utf-8 -*-
# copyright 2012-2014 romain dorgueil
# licensed under the apache license, version 2.0 (the "license");
# you may not use this file except in compliance with the license.
# you may obtain a copy of the license at
# unless required by applicable law or agreed to in writing, software
# distributed under the license is distributed on an "as is" basis,
# without warranties or conditions of any kind, either express or implied.
# see the license for the specific language governing permissions and
# limitations under the license.

from abc import ABCMeta, abstractmethod
from rdc.etl.error import AbstractError

[docs]class IHarness: """ ETL harness interface. The harness is basically the executable stuff that will actually run a job. """ __metaclass__ = ABCMeta @abstractmethod def __call__(self): """Actual harness run.""" raise AbstractError(self.__call__) @abstractmethod def add(self, transform): raise AbstractError(self.add) @abstractmethod def loop(self): raise AbstractError(self.loop)
class BaseHarness(IHarness): def initialize(self): pass def validate(self): pass def finalize(self): pass def __call__(self): """Run the Job.""" self.initialize() self.validate() _value = self.loop() self.finalize() return _value