Skip to content

Commit e7fbda1

Browse files
committed
Fix test and type/lint errors
1 parent 5a95138 commit e7fbda1

File tree

3 files changed

+21
-12
lines changed

3 files changed

+21
-12
lines changed

ckan/lib/search/index.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -136,7 +136,7 @@ def index_package(self,
136136

137137
if config.get_value('ckan.search.remove_deleted_packages'):
138138
# delete the package if there is no state, or the state is `deleted`
139-
if (not pkg_dict.get('state') or 'deleted' in pkg_dict.get('state')):
139+
if pkg_dict.get('state', 'deleted') == 'deleted':
140140
return self.delete_package(pkg_dict)
141141

142142
index_fields = RESERVED_FIELDS + list(pkg_dict.keys())

ckan/tests/cli/test_search_index.py

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -91,15 +91,23 @@ def test_deleted_only_visible_for_right_users(self):
9191
org1 = factories.Organization(user=user1)
9292
org2 = factories.Organization(user=user2)
9393
dataset1 = factories.Dataset(
94-
user=user1, private=True, owner_org=org1["name"], state="deleted"
94+
name="dataset-user-1",
95+
user=user1,
96+
private=True,
97+
owner_org=org1["name"],
98+
state="deleted"
9599
)
96100
dataset2 = factories.Dataset(
97-
user=user2, private=True, owner_org=org2["name"], state="deleted"
101+
name="dataset-user-2",
102+
user=user2,
103+
private=True,
104+
owner_org=org2["name"],
105+
state="deleted"
98106
)
99107

100108
search_results_1 = helpers.call_action(
101109
"package_search",
102-
{"user": user1["name"]},
110+
{"user": user1["name"], "ignore_auth": False},
103111
include_private=True,
104112
include_deleted=True
105113
)
@@ -109,7 +117,7 @@ def test_deleted_only_visible_for_right_users(self):
109117

110118
search_results_2 = helpers.call_action(
111119
"package_search",
112-
{"user": user2["name"]},
120+
{"user": user2["name"], "ignore_auth": False},
113121
include_private=True,
114122
include_deleted=True
115123
)

ckan/views/admin.py

Lines changed: 8 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22
from __future__ import annotations
33

44
import logging
5-
from typing import Any, Union, cast
5+
from typing import Any, Union, cast, List
66

77
from flask import Blueprint
88
from flask.views import MethodView
@@ -135,7 +135,6 @@ def post(self) -> Union[str, Response]:
135135

136136

137137
class TrashView(MethodView):
138-
deleted_entities: dict[str, Union[Query[Any], list[Any]]]
139138

140139
def __init__(self):
141140
self.deleted_packages = self._get_deleted_datasets()
@@ -169,20 +168,22 @@ def __init__(self):
169168
}
170169
}
171170

172-
def _get_deleted_datasets(self):
171+
def _get_deleted_datasets(
172+
self
173+
) -> Union["Query[model.Package]", List[Any]]:
173174
if config.get_value('ckan.search.remove_deleted_packages'):
174175
return self._get_deleted_datasets_from_db()
175176
else:
176177
return self._get_deleted_datasets_from_search_index()
177178

178-
def _get_deleted_datasets_from_db(self):
179+
def _get_deleted_datasets_from_db(self) -> "Query[model.Package]":
179180
return model.Session.query(
180181
model.Package
181182
).filter_by(
182183
state=model.State.DELETED
183184
)
184185

185-
def _get_deleted_datasets_from_search_index(self):
186+
def _get_deleted_datasets_from_search_index(self) -> List[Any]:
186187
query = search.query_for(model.Package)
187188
search_params = {
188189
'fq': '+state:deleted',
@@ -231,9 +232,9 @@ def purge_all(self):
231232
)
232233

233234
for action, deleted_entities in zip(actions, entities):
234-
235235
for entity in deleted_entities:
236-
ent_id = entity.id if hasattr(entity, 'id') else entity['id']
236+
ent_id = entity.id if hasattr(entity, 'id') \
237+
else entity['id'] # type: ignore
237238
logic.get_action(action)(
238239
{u'user': g.user}, {u'id': ent_id}
239240
)

0 commit comments

Comments
 (0)