1 files changed, 11 insertions, 1 deletions
diff --git a/src/main/java/io/trygvis/queue/QueueService.java b/src/main/java/io/trygvis/queue/QueueService.java
index ee74bf4..d97eaf0 100644
--- a/src/main/java/io/trygvis/queue/QueueService.java
+++ b/src/main/java/io/trygvis/queue/QueueService.java
@@ -12,11 +12,21 @@ public interface QueueService {
     void schedule(Queue queue, Date scheduled, List<String> arguments) throws SQLException;
 
     public static class TaskExecutionRequest {
+        public final long chunkSize;
         public final boolean stopOnError;
         // TODO: saveExceptions
 
-        public TaskExecutionRequest(boolean stopOnError) {
+        public TaskExecutionRequest(long chunkSize, boolean stopOnError) {
+            this.chunkSize = chunkSize;
             this.stopOnError = stopOnError;
         }
+
+        @Override
+        public String toString() {
+            return "TaskExecutionRequest{" +
+                    "chunkSize=" + chunkSize +
+                    ", stopOnError=" + stopOnError +
+                    '}';
+        }
     }
 }