MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-03-22 23:31:05 +07:00
Code Issues Packages Projects Releases Wiki Activity

[pycharm] PY-86058 Fix test flakiness

Browse Source 
Merge-request: IJ-MR-184791
Merged-by: David Lysenko <david.lysenko@jetbrains.com>

GitOrigin-RevId: 30ee0daf8fd25ebc38d94f8ea0019fbcf7c0f532
This commit is contained in:
David Lysenko
2025-12-08 17:02:33 +00:00
committed by intellij-monorepo-bot
parent 3b273aef44
commit fcf735a06d
1 changed files with 25 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
python/python-process-output/impl/test/com/intellij/python/junit5Tests/env/ProcessOutputControllerServiceTest.kt vendored
View File

@@ -13,7 +13,9 @@ import com.intellij.python.processOutput.impl.CoroutineNames
import com.intellij.python.processOutput.impl.ProcessOutputControllerService
import com.intellij.python.processOutput.impl.ProcessOutputControllerServiceLimits
import com.intellij.testFramework.common.timeoutRunBlocking
import com.intellij.testFramework.common.waitUntil
import com.intellij.testFramework.junit5.fixture.projectFixture
import com.intellij.util.io.awaitExit
import com.intellij.util.progress.sleepCancellable
import com.jetbrains.python.NON_INTERACTIVE_ROOT_TRACE_CONTEXT
import com.jetbrains.python.PythonBinary
@@ -41,7 +43,7 @@ class ProcessOutputControllerServiceTest {
fun `stress and limits test`(
@TempDir cwd: Path,
@PythonBinaryPath python: PythonBinary,
): Unit = timeoutRunBlocking(5.minutes) {
): Unit = timeoutRunBlocking(15.minutes) {
val service = projectFixture.get().service<ProcessOutputControllerService>()
val newLineLen = if (SystemInfoRt.isWindows) 2 else 1
@@ -63,10 +65,11 @@ class ProcessOutputControllerServiceTest {
// executing the file MAX_PROCESSES amount of times
repeat(ProcessOutputControllerServiceLimits.MAX_PROCESSES) {
runBin(binOnEel, Args(MAIN_PY, it.toString()))
}
// let the service catch up with the flows
sleepCancellable(200)
waitUntil {
service.firstLineOfLastProcess()?.startsWith("test $it") == true
}
}
// the amount of processes logged should exactly equal to MAX_PROCESSES
assertEquals(
@@ -91,17 +94,14 @@ class ProcessOutputControllerServiceTest {
// adding processes 2 times over the limit
repeat(ProcessOutputControllerServiceLimits.MAX_PROCESSES * 2) {
runBin(
binOnEel,
Args(
MAIN_PY,
(it + ProcessOutputControllerServiceLimits.MAX_PROCESSES).toString(),
),
)
}
val newIt = (it + ProcessOutputControllerServiceLimits.MAX_PROCESSES)
// catching up
sleepCancellable(200)
runBin(binOnEel, Args(MAIN_PY, newIt.toString()))
waitUntil {
service.firstLineOfLastProcess()?.startsWith("test $newIt") == true
}
}
// older processes beyond MAX_PROCESSES should be truncated
assertEquals(
@@ -172,6 +172,15 @@ class ProcessOutputControllerServiceTest {
)
}
private fun ProcessOutputControllerService.firstLineOfLastProcess(): String? =
loggedProcesses
.value
.lastOrNull()
?.lines
?.replayCache
?.getOrNull(0)
?.text
companion object {
const val MAIN_PY = "main.py"
@@ -192,6 +201,8 @@ class ProcessOutputControllerServiceTest {
process.inputStream.readAllBytes()
},
).awaitAll()
process.awaitExit()
}
}
}