Method Break

cpp/src/arrow/filesystem/azurefs.cc:1631–1659

\brief Break the lease. The lease will stay in the "Breaking" state for break_period seconds or less if the lease is expiring before that. https://learn.microsoft.com/en-us/rest/api/storageservices/lease-container#outcomes-of-use-attempts-on-containers-by-lease-state https://learn.microsoft.com/en-us/rest/api/storageservices/lease-blob#outcomes-of-use-attempts-on-blobs-by-lease-state

  /// https://learn.microsoft.com/en-us/rest/api/storageservices/lease-container#outcomes-of-use-attempts-on-containers-by-lease-state
  /// https://learn.microsoft.com/en-us/rest/api/storageservices/lease-blob#outcomes-of-use-attempts-on-blobs-by-lease-state
  Status Break(Azure::Nullable<std::chrono::seconds> break_period = {}) {
    auto remaining_time_ms = [this]() {
      const auto remaining_time = break_or_expires_at_ - SteadyClock::now();
      return std::chrono::duration_cast<std::chrono::milliseconds>(remaining_time);
    };
#ifndef NDEBUG
    if (break_period.HasValue() && !StillValidFor(*break_period)) {
      ARROW_LOG(WARNING)
          << "Azure Storage: requested break_period ("
          << break_period.ValueOr(std::chrono::seconds{0}).count()
          << "s) is too long or lease duration is too short for all the operations "
             "performed so far (lease expires in "
          << remaining_time_ms().count() << "ms)";
    }
#endif
    Blobs::BreakLeaseOptions options;
    options.BreakPeriod = break_period;
    try {
      lease_client_->Break(options);
      break_or_expires_at_ =
          std::min(break_or_expires_at_,
                   SteadyClock::now() + break_period.ValueOr(std::chrono::seconds{0}));
    } catch (const Core::RequestFailedException& exception) {
      return ExceptionToStatus(exception, "Failed to break the ",
                               lease_client_->GetLeaseId(), " lease expiring in ",
                               remaining_time_ms().count(), "ms");
    }
    return Status::OK();
  }

  /// \brief Break the lease before deleting or renaming the resource via the
  /// DataLakeFileSystemClient API.