Google Pub/Sub не срабатывает в заданное время.

В моем коде есть функция, которая проверяет ожидающие криптотранзакции и обновляет статус на основе определенной логики. Каждый раз, когда создается новая криптотранзакция, сообщение отправляется в топик pub/sub, чтобы сработать через 30 секунд и проверить статус этой транзакции. Проблема заключается в том, что таймер на 30 секунд игнорируется, и триггер срабатывает немедленно, не давая криптотранзакции шанс быть обработанной. Это пример кода, я использую функции облака Firebase и запускаю эту функцию для планирования темы, используя "@google-cloud/pubsub": "^4.5.0",:

  public async scheduleNextCheck({
    uid,
    operationID,
    pendingCryptoOperation,
  }: {
    uid: string;
    operationID: string;
    pendingCryptoOperation: Operation;
  }) {
    const pubsub = new PubSub();
    const data = {
      operationID,
      uid,
      "api-version": "v1",
      differenceInSeconds: 0,
    };
    const publishTime = this.calculateNextTriggerTimeStamp(
      pendingCryptoOperation
    );

    // Преобразование временной метки Firestore в миллисекунды
    const milliseconds =
      publishTime.seconds * 1000 +
      Math.floor(publishTime.nanoseconds / 1000000);

    // Создание объекта Date для времени публикации
    let publishDate = new Date(milliseconds);

    // Рассчитываем разницу между текущим временем и временем публикации
    const now = new Date();
    const differenceInMilliseconds = publishDate.getTime() - now.getTime();
    const differenceInSeconds = Math.floor(differenceInMilliseconds / 1000);
    data.differenceInSeconds = differenceInSeconds;

    // Убедитесь, что время публикации в будущем
    if (differenceInMilliseconds < 0) {
      console.warn("Время публикации в прошлом. Корректировка на текущее время.");
      publishDate = now; // или обработать этот случай должным образом
    }

    const messageId = await pubsub
      .topic(this.runtimeConfig.pubSubPendingOperationsTopic, {
        enableOpenTelemetryTracing: true,
      })
      .publishMessage({
        json: data,
        publishTime: Timestamp.fromDate(publishDate),
      });

    Logger.info(`Триггер запланирован для операции ${operationID}`, {
      operationID,
      status: OperationStatus.pending,
      uid,
      messageId,
      publishTime: publishDate.toISOString(),
      differenceInSeconds,
    });
  }

А это calculateNextTriggerTimeStamp просто для справки:

  public calculateNextTriggerTimeStamp(operation: Operation): Timestamp {
    const { createdAt } = operation;
    const now = Date.now();
    const fiveMinutesInMillis = 5 * 60 * 1000;
    const thirtySecondsInMillis = 30 * 1000;

    // Время, прошедшее с момента создания операции
    const timeElapsed = now - createdAt.toMillis();

    // Первые 5 минут: проверка каждые 30 секунд
    if (timeElapsed <= fiveMinutesInMillis) {
      return Timestamp.fromMillis(now + thirtySecondsInMillis);
    }

    // После 5 минут начинаем увеличивать интервал
    const intervals = [
      { duration: 10 * 60 * 1000, interval: 1 * 60 * 1000 }, // Следующие 10 минут: каждую минуту
      { duration: 30 * 60 * 1000, interval: 5 * 60 * 1000 }, // Следующие 30 минут: каждые 5 минут
      { duration: 2 * 60 * 60 * 1000, interval: 15 * 60 * 1000 }, // Следующие 2 часа: каждые 15 минут
      { duration: 6 * 60 * 60 * 1000, interval: 30 * 60 * 1000 }, // Следующие 6 часов: каждые 30 минут
      { duration: 34 * 60 * 60 * 1000, interval: 1 * 60 * 60 * 1000 }, // Остальное время до 48 часов: каждую 1 час
    ];

    let cumulativeTime = fiveMinutesInMillis;

    for (const step of intervals) {
      cumulativeTime += step.duration;
      if (timeElapsed <= cumulativeTime) {
        const remainingTimeInStep = cumulativeTime - timeElapsed;
        const nextTriggerInMillis =
          step.interval - (remainingTimeInStep % step.interval);
        return Timestamp.fromMillis(now + nextTriggerInMillis);
      }
    }

    throw ErrorMessages.TaskExceedsMaxInterval;
  }

Почему планирование не работает? Есть ли проблема в самом пакете?