Get entire source as DataFrame
(self, source_name: str, table_name: str | None = None)
| 505 | return source.query(sql) |
| 506 | |
| 507 | def get_df(self, source_name: str, table_name: str | None = None) -> pd.DataFrame: |
| 508 | """Get entire source as DataFrame""" |
| 509 | source = self._get_or_create_source(source_name) |
| 510 | |
| 511 | if isinstance(source, PostgresSource): |
| 512 | if table_name is None: |
| 513 | raise ValueError("table_name is required for Postgres sources") |
| 514 | return source.to_df(table_name) |
| 515 | return source.to_df() |
| 516 | |
| 517 | def _get_or_create_source(self, source_name: str) -> DataSource: |
| 518 | """Get an existing source or create a new one from a file path.""" |
no test coverage detected