import luigi

from etl.workflow.reporter import ExecuteAnalysis


class PdcmEtl(luigi.Task):
    """ Executes the ETL process for the specified providers. """
    data_dir = luigi.Parameter()
    data_dir_out = luigi.Parameter()
    providers = luigi.ListParameter()

    def requires(self):
        return ExecuteAnalysis()


if __name__ == "__main__":
    luigi.run()
