@task(log_stdout=True)
def load_path_config():
    path_config = load_config()
    return path_config


@task(log_stdout=True)
def harvest_metadata(path_config):
	metascraper = metaScraper(path_config)
	metascraper.run()

@task(log_stdout=True)
def harvest_master_data(path_config):
    scraper = Scraper(path_config)
    scraper.run()

with Flow("Harvest_Demo") as flow:
    path_config = load_path_config()
    harvest_metadata(path_config)
    harvest_master_data(path_config,upstream_tasks=[harvest_metadata])