Retrieves the list of data sources from the registry. Args: allow_cache: Whether to allow returning data sources from a cached registry. tags: Filter by tags. Returns: A list of data sources.
(
self, allow_cache: bool = False, tags: Optional[dict[str, str]] = None
)
| 667 | ) |
| 668 | |
| 669 | def list_data_sources( |
| 670 | self, allow_cache: bool = False, tags: Optional[dict[str, str]] = None |
| 671 | ) -> List[DataSource]: |
| 672 | """ |
| 673 | Retrieves the list of data sources from the registry. |
| 674 | |
| 675 | Args: |
| 676 | allow_cache: Whether to allow returning data sources from a cached registry. |
| 677 | tags: Filter by tags. |
| 678 | |
| 679 | Returns: |
| 680 | A list of data sources. |
| 681 | """ |
| 682 | return self.registry.list_data_sources( |
| 683 | self.project, allow_cache=allow_cache, tags=tags |
| 684 | ) |
| 685 | |
| 686 | def get_entity(self, name: str, allow_registry_cache: bool = False) -> Entity: |
| 687 | """ |
no outgoing calls