Skip to content

Commit 62ecf7f

Browse files
committed
Fix concatenate
1 parent b858060 commit 62ecf7f

File tree

2 files changed

+6
-3
lines changed

2 files changed

+6
-3
lines changed

bcodmo_frictionless/bcodmo_pipeline_processors/concatenate.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -185,7 +185,7 @@ def func(package):
185185

186186
if redis_conn is not None:
187187
redis_conn.sadd(
188-
get_redis_progress_resource_key(_cache_id),
188+
get_redis_progress_resource_key(cache_id),
189189
target["name"],
190190
)
191191
package.pkg.descriptor["resources"] = new_resources

bcodmo_frictionless/bcodmo_pipeline_processors/edit_cells.py

+5-2
Original file line numberDiff line numberDiff line change
@@ -21,8 +21,11 @@ def process_resource(rows, edited, missing_values):
2121
for row in rows:
2222
row_counter += 1
2323
try:
24-
if row_counter in edited:
25-
edited_cells = edited.pop(row_counter)
24+
if row_counter in edited or str(row_counter) in edited:
25+
try:
26+
edited_cells = edited.pop(row_counter)
27+
except KeyError:
28+
edited_cells = edited.pop(str(row_counter))
2629
for edited_cell in edited_cells:
2730
field = edited_cell.get("field")
2831
value = edited_cell.get("value")

0 commit comments

Comments
 (0)