Create a new scraping pipeline.
(pipeline: PipelineCreate)
| 15 | |
| 16 | @router.post("/", response_model=Pipeline) |
| 17 | async def create_pipeline(pipeline: PipelineCreate): |
| 18 | """Create a new scraping pipeline.""" |
| 19 | pipeline_id = str(uuid.uuid4()) |
| 20 | new_pipeline = Pipeline( |
| 21 | id=pipeline_id, |
| 22 | name=pipeline.name, |
| 23 | description=pipeline.description, |
| 24 | urls=pipeline.urls or [], |
| 25 | schema=pipeline.schema or {}, |
| 26 | code="", |
| 27 | status="idle", |
| 28 | created_at=datetime.utcnow(), |
| 29 | updated_at=datetime.utcnow() |
| 30 | ) |
| 31 | |
| 32 | pipelines_store[pipeline_id] = new_pipeline |
| 33 | return new_pipeline |
| 34 | |
| 35 | @router.get("/{pipeline_id}", response_model=Pipeline) |
| 36 | async def get_pipeline(pipeline_id: str): |