test(spanner): clear stale backups before running BackupTest

Author: cy-yun

Spanner/tests/System/BackupTest.php

@@ -19,6 +19,8 @@
 
 use Google\Cloud\Core\Exception\BadRequestException;
 use Google\Cloud\Core\Exception\ConflictException;
+use Google\Cloud\Core\Exception\FailedPreconditionException;
+use Google\Cloud\Core\Exception\ServiceException;
 use Google\Cloud\Core\LongRunning\LongRunningOperation;
 use Google\Cloud\Core\Testing\System\SystemTestCase;
 use Google\Cloud\Spanner\Admin\Database\V1\Client\DatabaseAdminClient;
@@ -78,13 +80,17 @@ public static function setUpTestFixtures(): void
             self::$deletionQueue->add(function () {
                 self::getDatabaseInstance(self::$dbName1)->drop();
             });
+        } else {
+            self::cleanUpPendingBackups(self::$dbName1);
         }
 
         if (!self::$dbName2 = getenv('GOOGLE_CLOUD_SPANNER_TEST_BACKUP_DATABASE_2')) {
             self::$dbName2 = uniqid(self::TESTING_PREFIX);
             self::$deletionQueue->add(function () {
                 self::getDatabaseInstance(self::$dbName2)->drop();
             });
+        } else {
+            self::cleanUpPendingBackups(self::$dbName2);
         }
 
         $db1 = self::getDatabaseInstance(self::$dbName1);
@@ -179,6 +185,9 @@ public function testCreateBackup()
         $this->assertNotNull($metadata);
     }
 
+    /**
+     * @depends testCreateBackup
+     */
     public function testCreateBackupRequestFailed()
     {
         $backupId = uniqid(self::BACKUP_PREFIX);
@@ -209,6 +218,9 @@ public function testCreateBackupRequestFailed()
         $this->assertFalse($backup->exists());
     }
 
+    /**
+     * @depends testCreateBackup
+     */
     public function testCreateBackupInvalidArgument()
     {
         $backupId = uniqid(self::BACKUP_PREFIX);
@@ -734,4 +746,26 @@ private function pollWithExtendedTimeout($op)
 
         return $op;
     }
+
+    private static function cleanUpPendingBackups($dbName)
+    {
+        $dbFullName = self::getDatabaseInstance($dbName)->name();
+        try {
+            foreach (self::$instance->backupOperations() as $op) {
+                if (!$op->done()) {
+                    $metadata = $op->info()['metadata'] ?? [];
+                    if (isset($metadata['database']) && $metadata['database'] === $dbFullName) {
+                        try {
+                            $op->cancel();
+                            $op->pollUntilComplete(['maxPollingDurationSeconds' => 120]);
+                        } catch (\Exception $e) {
+                            // Ignore exceptions from cancelled operations
+                        }
+                    }
+                }
+            }
+        } catch (\Exception $e) {
+            // Ignore errors
+        }
+    }
 }