diff --git a/internal/component/database_observability/mysql/collector/schema_table_test.go b/internal/component/database_observability/mysql/collector/schema_table_test.go index 8a9c6d1fea..f92e92fa32 100644 --- a/internal/component/database_observability/mysql/collector/schema_table_test.go +++ b/internal/component/database_observability/mysql/collector/schema_table_test.go @@ -257,12 +257,18 @@ func TestSchemaTable(t *testing.T) { require.NoError(t, err) require.Eventually(t, func() bool { - return collector.Stopped() + return len(lokiClient.Received()) == 1 }, 5*time.Second, 100*time.Millisecond) collector.Stop() lokiClient.Stop() + lokiEntries := lokiClient.Received() + for _, entry := range lokiEntries { + require.Equal(t, model.LabelSet{"job": database_observability.JobName}, entry.Labels) + } + require.Equal(t, `level=info msg="schema detected" op="schema_detection" instance="mysql-db" schema="some_schema"`, lokiEntries[0].Line) + err = mock.ExpectationsWereMet() require.NoError(t, err) })