add heartbeat (#29056)
This commit is contained in:
parent
cb1b6502f1
commit
3af88c5550
@ -473,7 +473,12 @@ Future<void> _processTestOutput(
|
|||||||
Stream<String> testOutput,
|
Stream<String> testOutput,
|
||||||
bq.TabledataResourceApi tableData,
|
bq.TabledataResourceApi tableData,
|
||||||
) async {
|
) async {
|
||||||
|
final Timer heartbeat = Timer.periodic(const Duration(seconds: 30), (Timer timer) {
|
||||||
|
print('Processing...');
|
||||||
|
});
|
||||||
|
|
||||||
await testOutput.forEach(formatter.processRawOutput);
|
await testOutput.forEach(formatter.processRawOutput);
|
||||||
|
heartbeat.cancel();
|
||||||
formatter.finish();
|
formatter.finish();
|
||||||
if (tableData == null || formatter.tests.isEmpty) {
|
if (tableData == null || formatter.tests.isEmpty) {
|
||||||
return;
|
return;
|
||||||
|
Loading…
x
Reference in New Issue
Block a user