Creates a RequestSource object.
(
self,
*,
name: str,
schema: List[Field],
timestamp_field: Optional[str] = None,
description: Optional[str] = "",
tags: Optional[Dict[str, str]] = None,
owner: Optional[str] = "",
)
| 609 | owner: str |
| 610 | |
| 611 | def __init__( |
| 612 | self, |
| 613 | *, |
| 614 | name: str, |
| 615 | schema: List[Field], |
| 616 | timestamp_field: Optional[str] = None, |
| 617 | description: Optional[str] = "", |
| 618 | tags: Optional[Dict[str, str]] = None, |
| 619 | owner: Optional[str] = "", |
| 620 | ): |
| 621 | """Creates a RequestSource object.""" |
| 622 | super().__init__( |
| 623 | name=name, |
| 624 | timestamp_field=timestamp_field, |
| 625 | description=description, |
| 626 | tags=tags, |
| 627 | owner=owner, |
| 628 | ) |
| 629 | self.schema = schema |
| 630 | |
| 631 | def validate(self, config: RepoConfig): |
| 632 | raise NotImplementedError |