Skip to content

Commit 3be8d22

Browse files
committed
fix
1 parent 3bbdbbe commit 3be8d22

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

deeplake/util/transform.py

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,7 @@ def inner(num_samples):
9898
return inner
9999

100100

101-
def _extend_data_slice(data_slice, transform_dataset, transform_fn):
101+
def _extend_data_slice(data_slice, transform_dataset, transform_fn, pg_callback):
102102
extend_fn, args, kwargs = (
103103
transform_fn.func,
104104
transform_fn.args,
@@ -154,7 +154,7 @@ def _transform_and_append_data_slice(
154154
out_tensor.non_numpy_only()
155155
transform_tensor.extend(out_tensor.items)
156156
out_tensor.items.clear()
157-
if pg_callback:
157+
if pg_callback is not None:
158158
pg_callback(1)
159159

160160
transform_dataset.flush()
@@ -226,7 +226,9 @@ def store_data_slice_with_pbar(pg_callback, transform_input: Tuple) -> Dict:
226226
)
227227

228228
if extend_only:
229-
_extend_data_slice(data_slice, transform_dataset, pipeline.functions[0])
229+
_extend_data_slice(
230+
data_slice, transform_dataset, pipeline.functions[0], pg_callback
231+
)
230232
else:
231233
_transform_and_append_data_slice(
232234
data_slice, transform_dataset, pipeline, rel_tensors, skip_ok, pg_callback

0 commit comments

Comments
 (0)