Skip to content

Commit

Permalink
log paths on copy
Browse files Browse the repository at this point in the history
  • Loading branch information
abhijat committed Jan 18, 2024
1 parent 48d0729 commit f609928
Showing 1 changed file with 9 additions and 10 deletions.
19 changes: 9 additions & 10 deletions tests/rptest/archival/s3_client.py
Original file line number Diff line number Diff line change
@@ -1,21 +1,19 @@
import datetime
import threading

from rptest.archival.shared_client_utils import key_to_topic

import boto3

from botocore import UNSIGNED
from botocore.config import Config
from botocore.exceptions import ClientError

from concurrent.futures import ThreadPoolExecutor
import datetime
from functools import wraps
from itertools import islice
from time import sleep
from typing import Iterator, NamedTuple, Union, Optional

import boto3
from botocore import UNSIGNED
from botocore.config import Config
from botocore.exceptions import ClientError
from ducktape.utils.util import wait_until

from rptest.archival.shared_client_utils import key_to_topic


class SlowDown(Exception):
pass
Expand Down Expand Up @@ -332,6 +330,7 @@ def _copy_single_object(self, bucket, src, dst):
"""Copy object to another location within the bucket"""
try:
src_uri = f"{bucket}/{src}"
self.logger.debug(f"Copying {src_uri} to {dst} on {bucket}")
return self._cli.copy_object(Bucket=bucket,
Key=dst,
CopySource=src_uri)
Expand Down

0 comments on commit f609928

Please sign in to comment.