diff --git a/cpp/arcticdb/version/version_core.cpp b/cpp/arcticdb/version/version_core.cpp
index d915f2648d..bf945a5c4f 100644
--- a/cpp/arcticdb/version/version_core.cpp
+++ b/cpp/arcticdb/version/version_core.cpp
@@ -558,7 +558,7 @@ folly::Future<std::vector<EntityId>> schedule_clause_processing(
     auto entity_ids_vec_fut = folly::collect(*futures).via(&async::io_executor());
 
     const auto scheduling_iterations = num_scheduling_iterations(*clauses);
-    for (auto i = 0UL; i < scheduling_iterations; ++i) {
+    for (auto i = 1UL; i < scheduling_iterations; ++i) {
         entity_ids_vec_fut = std::move(entity_ids_vec_fut).thenValue([clauses, scheduling_iterations, i] (std::vector<std::vector<EntityId>>&& entity_id_vectors) {
             ARCTICDB_RUNTIME_DEBUG(log::memory(), "Scheduling iteration {} of {}", i, scheduling_iterations);
 
diff --git a/python/arcticdb/version_store/processing.py b/python/arcticdb/version_store/processing.py
index 5f77cda66d..f58944376f 100644
--- a/python/arcticdb/version_store/processing.py
+++ b/python/arcticdb/version_store/processing.py
@@ -585,7 +585,6 @@ def agg(self, aggregations: Dict[str, Union[str, Tuple[str, str]]]):
             self._python_clauses[-1].aggregations = aggregations
         return self
 
-
     def resample(
             self,
             rule: Union[str, pd.DateOffset],
@@ -780,7 +779,6 @@ def resample(
         self._python_clauses = self._python_clauses + [PythonResampleClause(rule=rule, closed=boundary_map[closed], label=boundary_map[label], offset=offset_ns, origin=origin)]
         return self
 
-
     # TODO: specify type of other must be QueryBuilder with from __future__ import annotations once only Python 3.7+
     # supported
     def then(self, other):