@Override
    public InputStream getTaskStateFile(String state, String name) throws IOException {
        return getTaskStateFile(state, name, false, true);
    }
@Test
    void shouldGetTaskStateFileFromTriggerContext() throws IOException {
        // Given
        StorageInterface storageInterface = Mockito.mock(StorageInterface.class);
        InputStream is = new ByteArrayInputStream(new byte[0]);
        Mockito.when(storageInterface.get(any(), eq(URI.create("/namespace/states/state/name")))).thenReturn(is);
        InternalStorage storage = new InternalStorage(StorageContext.forTrigger(null,
            "namespace",
            "flowid",
            "executionId",
            "triggerId"), storageInterface);

        // When
        InputStream result = storage.getTaskStateFile("state", "name", true, true);

        // Then
        Assertions.assertEquals(result, is);
    }