Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster/dagster/core/storage/runs/sql_run_storage.py
| Show First 20 Lines • Show All 189 Lines • ▼ Show 20 Lines | def _runs_query(self, filters=None, cursor=None, limit=None, columns=None): | ||||
| if columns is None: | if columns is None: | ||||
| columns = ["run_body"] | columns = ["run_body"] | ||||
| base_query_columns = [getattr(RunsTable.c, column) for column in columns] | base_query_columns = [getattr(RunsTable.c, column) for column in columns] | ||||
| # If we have a tags filter, then we need to select from a joined table | # If we have a tags filter, then we need to select from a joined table | ||||
| if filters.tags: | if filters.tags: | ||||
| base_query = db.select(base_query_columns).select_from( | base_query = db.select(base_query_columns).select_from( | ||||
| RunsTable.outerjoin(RunTagsTable, RunsTable.c.run_id == RunTagsTable.c.run_id) | RunsTable.join(RunTagsTable, RunsTable.c.run_id == RunTagsTable.c.run_id) | ||||
| ) | ) | ||||
| else: | else: | ||||
| base_query = db.select(base_query_columns).select_from(RunsTable) | base_query = db.select(base_query_columns).select_from(RunsTable) | ||||
| query = self._add_filters_to_query(base_query, filters) | query = self._add_filters_to_query(base_query, filters) | ||||
| query = self._add_cursor_limit_to_query(query, cursor, limit) | query = self._add_cursor_limit_to_query(query, cursor, limit) | ||||
| return query | return query | ||||
| ▲ Show 20 Lines • Show All 362 Lines • Show Last 20 Lines | |||||