Unanswered
Hey Currently Trying To Run A Pipeline Locally To Test A Pipeline Component With
So it seems to be an issue with the component parameter called in:
` @PipelineDecorator.pipeline(
name="VINZ Auto-Retrain",
project="VINZ",
version="0.0.1",
pipeline_execution_queue="Quad_VCPU_16GB"
)
def executing_pipeline(start_date, end_date):
print("Starting VINZ Auto-Retrain pipeline...")
print(f"Start date: {start_date}")
print(f"End date: {end_date}")
window_dataset_id = generate_dataset(start_date, end_date)
if name == 'main':
PipelineDecorator.run_locally()
executing_pipeline(
start_date="2022-01-01",
end_date="2022-03-02"
) `
Also tried with specifying named parameters like : generate_dataset(start_date=start_date, end_date=end_date)
but no effect
160 Views
0
Answers
2 years ago
one year ago