@Test
    public void test_execute_success() {
        createRequiredDirectories();

        // Setup successful process execution
        mockProcessHelper.setExitValue(0);
        mockProcessHelper.setOutput("Suggest creation successful");

        String result = suggestJob.execute();

        assertNotNull(result);
        assertTrue(result.contains("Session Id:"));
        assertNotNull(suggestJob.sessionId);

        serializer.setProperty("http://xmlpull.org/v1/doc/properties.html#serializer-indentation", "  ");
        serializer.setProperty("http://xmlpull.org/v1/doc/properties.html#serializer-line-separator", "\n");
        serializer.setOutput(writer);
        serializer.startDocument(coreExtensions.getModelEncoding(), null);
        writeCoreExtensions(coreExtensions, "extensions", serializer);
        serializer.endDocument();

          script: |
            if (context.payload.pull_request && context.payload.pull_request.head.repo.fork) {
                core.setOutput('sys-prop-args', '-DagreePublicBuildScanTermOfService=yes -Ddevelocity.edge.discovery=false -DcacheNode=us --scan')
            } else {
                core.setOutput('sys-prop-args', '')
            }
      - name: Setup Gradle
        uses: gradle/actions/setup-gradle@v6
        with:

        thread.start();

        Thread.sleep(50);

        String output1 = thread.getOutput();
        boolean contains1 = thread.contains("concurrent1");

        thread.join(1000);

        String output2 = thread.getOutput();
        boolean contains2 = thread.contains("concurrent1");

        assertNotNull(output1);
        assertNotNull(output2);

        SmbPipeInputStream in1 = handle.getInput();
        SmbPipeInputStream in2 = handle.getInput();
        SmbPipeOutputStream out1 = handle.getOutput();
        SmbPipeOutputStream out2 = handle.getOutput();

        // Assert: same instances are returned subsequently
        assertSame(in1, in2, "Input stream should be cached");
        assertSame(out1, out2, "Output stream should be cached");

        assertEquals("c", item1.getOutput());

        OptionalEntity<CharMappingItem> result2 = charMappingFile.get(2L);
        assertTrue(result2.isPresent());
        CharMappingItem item2 = result2.get();
        assertEquals(2L, item2.getId());
        assertArrayEquals(new String[] { "d", "e" }, item2.getInputs());
        assertEquals("f", item2.getOutput());

        }
        return this.input;
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.SmbPipeHandle#getOutput()
     */
    @Override
    public SmbPipeOutputStream getOutput() throws CIFSException {
        if (!this.open) {
            throw new SmbException("Already closed");
        }

        if (this.output != null) {

     * @throws CIFSException if an error occurs while getting the stream.
     */
    @Test
    public void testGetOutputStream() throws CIFSException {
        assertEquals(mockOutputStream, smbPipeHandle.getOutput(), "getOutput() should return the correct output stream.");
    }

    /**
     * Tests related to the lifecycle management of the handle (e.g., closing).
     */
    @Nested
    public class LifecycleManagementTest {

        assertEquals(2, callbackResults.size());
        assertEquals("integration test", callbackResults.get(0));
        assertEquals("second line", callbackResults.get(1));

        String output = thread.getOutput();
        assertTrue(output.contains("integration test"));
        assertTrue(output.contains("second line"));
    }

    @Test
    public void test_defaultBufferSizeConstant() throws IOException {

        assertEquals("line1 line2", item.getOutput());
    }

    @Test
    public void test_constructor_withNullOutput() {
        // Test with null output
        String[] inputs = { "input" };
        CharMappingItem item = new CharMappingItem(1L, inputs, null);

        assertNull(item.getOutput());
    }

    @Test
    public void test_constructor_withUnsortedInputs() {