diff --git a/packages/shell-api/src/stream-processor.ts b/packages/shell-api/src/stream-processor.ts index 26590d542..54b0912e8 100644 --- a/packages/shell-api/src/stream-processor.ts +++ b/packages/shell-api/src/stream-processor.ts @@ -25,9 +25,10 @@ export default class StreamProcessor extends ShellApiWithMongoClass { } @returnsPromise - async start() { + async start(options: Document = {}) { return await this._streams._runStreamCommand({ startStreamProcessor: this.name, + ...options, }); }