Submodule fix.

Signed-off-by: Michal Zientkiewicz <michalz@nvidia.com>

Author: mzient

dali/kernels/slice/slice_cpu.h

@@ -333,7 +333,7 @@ void SliceKernel(ExecutionEngine &exec_engine,
   int nblocks = split_shape(split_factor, out_shape, req_nblocks, min_blk_sz, skip_dim_mask);
 
   if (nblocks == 1) {
-    exec_engine.AddWork([=](int) {
+    exec_engine.AddTask([=](int) {
       SliceKernel(out_data, in_data, out_strides, in_strides, out_shape, in_shape, args.anchor,
                   args.step, GetPtr<OutputType>(args.fill_values), args.channel_dim);
     }, kSliceCost * volume(out_shape), false);  // do not start work immediately

dali/operators/image/color/equalize.cc

@@ -69,7 +69,7 @@ class EqualizeCPU : public Equalize<CPUBackend> {
     for (int sample_idx = 0; sample_idx < num_samples; sample_idx++) {
       auto out_sample = out_view[sample_idx];
       auto in_sample = in_view[sample_idx];
-      tp.AddWork([this, out_sample, in_sample](int) { RunSample(out_sample, in_sample); },
+      tp.AddTask([this, out_sample, in_sample](int) { RunSample(out_sample, in_sample); },
                  in_sample.shape.num_elements());
     }
     tp.RunAll();

dali/operators/image/convolution/filter.cc

@@ -275,7 +275,7 @@ class FilterOpCpuImpl : public OpImplBase<CPUBackend> {
       ocv::with_border_handler(
           input_desc_.is_valid_mode, border_type_, sample_idx, fill_values, [&](auto ocv_handler) {
             for (auto&& views : planes_range) {
-              tp.AddWork(
+              tp.AddTask(
                   [this, views, sample_filter, sample_anchor, ocv_handler](int) {
                     auto& [sample_out, sample_in] = views;
                     RunSample(sample_out, sample_filter, sample_in, sample_anchor, ocv_handler);

dali/operators/reader/fits_reader_op.cc

@@ -1,4 +1,4 @@
-// Copyright (c) 2020-2022, NVIDIA CORPORATION & AFFILIATES. All rights reserved.
+// Copyright (c) 2020-2023, NVIDIA CORPORATION & AFFILIATES. All rights reserved.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -43,7 +43,7 @@ This operator can be used in the following modes:
 2. Read file names from a text file indicated in ``file_list`` argument.
 3. Read files listed in ``files`` argument.
 4. Number of outputs per sample corresponds to the length of ``hdu_indices`` argument. By default,
-first HDU with data is read from each file, so the number of outputs defaults to 1. 
+first HDU with data is read from each file, so the number of outputs defaults to 1.
 )")
     .NumInput(0)
     .OutputFn(detail::FitsReaderOutputFn)
@@ -78,7 +78,7 @@ If ``file_root`` is provided, the paths are treated as being relative to it.
 This argument is mutually exclusive with ``file_list``.)",
                                     nullptr)
     .AddOptionalArg("hdu_indices",
-                    R"(HDU indices to read. If not provided, the first HDU after the primary 
+                    R"(HDU indices to read. If not provided, the first HDU after the primary
 will be yielded. Since HDUs are indexed starting from 1, the default value is as follows: hdu_indices = [2].
 Size of the provided list hdu_indices defines number of outputs per sample.)",
                     std::vector<int>{2})
@@ -104,7 +104,7 @@ void FitsReaderCPU::RunImpl(Workspace &ws) {
                     sample.data[output_idx].nbytes());
       };
       if (threaded) {
-        ws.GetThreadPool().AddWork(std::move(copy_task), -file_idx);
+        ws.GetThreadPool().AddTask(std::move(copy_task), -file_idx);
       } else {
         copy_task(0);
       }

dali/operators/reader/numpy_reader_op.cc

@@ -302,7 +302,7 @@ void NumpyReaderCPU::Prefetch() {
         auto target_mem = static_cast<char*>(tmp_mem.get()) - target_data_offset + read_offset;
         // where to read from counting from the file start
         auto file_offset = read_offset + align_down(target->data_offset, o_direct_alignm_);
-        thread_pool_.AddWork([this, &target, file, read_size, target_mem, file_offset, read_tail]
+        thread_pool_.AddTask([this, &target, file, read_size, target_mem, file_offset, read_tail]
                              (int tid) {
           Index ret = file->ReadAt(target_mem, read_size, file_offset);
           DALI_ENFORCE(ret >= static_cast<Index>(read_tail) &&

dali/operators/reader/tfrecord_reader_op.cc

@@ -1,4 +1,4 @@
-// Copyright (c) 2017-2018, NVIDIA CORPORATION. All rights reserved.
+// Copyright (c) 2017-2023, NVIDIA CORPORATION & AFFILIATES. All rights reserved.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -124,7 +124,7 @@ void TFRecordReader::Prefetch() {
   auto idx_loader = dynamic_cast<IndexedFileLoader*>(loader_.get());
   while (idx_loader->AnyWorkLeft()) {
     auto work = idx_loader->GetReadWork();
-    thread_pool_.AddWork([work = std::move(work)] (int tid) {
+    thread_pool_.AddTask([work = std::move(work)] (int tid) {
                           work();
                         });
   }