Class CellExecution

src/kernels/execution/cellExecution.ts:82–585

 *
 */
export class CellExecution implements ICellExecution, IDisposable {
    public readonly type = 'cell';
    public get result(): Promise<void> {
        return this._result.promise;
    }
    private readonly _result = createDeferred<void>();

    private started?: boolean;

    private _completed?: boolean;
    private endTime?: number;
    private execution?: NotebookCellExecution & {
        /**
         * Whether we have received a response for the execution request sent to the kernel.
         * I.e. has the kernel acknowledged the execution request.
         */
        started?: boolean;
    };
    private cancelHandled = false;
    private disposed?: boolean;
    private request: Kernel.IShellFuture<KernelMessage.IExecuteRequestMsg, KernelMessage.IExecuteReplyMsg> | undefined;
    private readonly disposables: IDisposable[] = [];
    private cellExecutionHandler?: CellExecutionMessageHandler;
    private session?: IKernelSession;
    private cancelRequested?: boolean;
    private _executionOrder?: number;
    public get executionOrder() {
        return this._executionOrder;
    }
    private constructor(
        public readonly cell: NotebookCell,
        private readonly codeOverride: string | undefined,
        private readonly kernelConnection: Readonly<KernelConnectionMetadata>,
        private readonly controller: IKernelController,
        private readonly requestListener: CellExecutionMessageHandlerService,
        private readonly resumeExecution?: ResumeCellExecutionInformation,
        private readonly federatedAuthSqlBlockCodeGenerator?: IFederatedAuthSqlBlockCodeGenerator
    ) {
        workspace.onDidCloseTextDocument(
            (e) => {
                // If the cell is deleted, then dispose the request object.
                // No point keeping it alive, just chewing resources.
                if (e === this.cell.document) {
                    logger.info(
                        `Disposing request as the cell (${this.cell.index}) was deleted ${getDisplayPath(
                            this.cell.notebook.uri
                        )}`
                    );
                    try {
                        this.request?.dispose(); // NOSONAR
                    } catch (e) {
                        logger.error(`Error during cell execution dispose: ${e}`);
                    }
                    if (this.started && !this._completed) {
                        this.completedDueToCancellation();
                    }
                }
            },