def METHOD_NAME(task):
    def seed_task():
        client = bigquery.Client()
        job_config = bigquery.LoadJobConfig()
        schema_path = os.path.join(dags_folder, 'resources/stages/seed/schemas/{task}.json'.format(task=task))
        job_config.schema = read_bigquery_schema_from_file(schema_path)
        job_config.source_format = bigquery.SourceFormat.CSV
        job_config.skip_leading_rows = 1
        job_config.write_disposition = 'WRITE_TRUNCATE'
        job_config.ignore_unknown_values = True
        file_path = os.path.join(dags_folder, 'resources/stages/seed/data/{task}.csv'.format(task=task))
        table_ref = client.dataset(project='blockchain-etl-internal', dataset_id='common').table(task)
        load_job = client.load_table_from_file(open(file_path, mode='r+b'), table_ref, job_config=job_config)
        submit_bigquery_job(load_job, job_config)
        assert load_job.state == 'DONE'
    seed_operator = PythonOperator(
        task_id='seed_{task}'.format(task=task),
        python_callable=seed_task,
        execution_timeout=timedelta(minutes=30),
        dag=dag
    )
    return seed_operator