Commit 28f9de48 authored by James Clark's avatar James Clark
Browse files

Provide empty list if all files registered

parent c1cdc67d
Pipeline #78783 passed with stages
in 46 seconds
......@@ -303,6 +303,7 @@ def daemon(aparser):
aparser.cachefile)
# If necessary, wait for diskcache file to appear
# FIXME: add exception for bad diskcache (i.e., retry if exists but is empty/incomplete)
# FIXME: update minimum_gps to time of last check, so we don't waste
# time checking files we just registered
while True:
......
......@@ -136,6 +136,7 @@ class DatasetInjector(object):
if not files:
self.logger.info("No new replicas to add at %s",
self.rse_info['rse'])
self.files = []
else:
self._enumerate_uploads(files)
......@@ -146,7 +147,7 @@ class DatasetInjector(object):
logger = self.logger
try:
# Add rule in here if DID does not exist
logger.debug("Trying to create dataset: %s", self.dataset_name)
logger.info("Trying to create dataset: %s", self.dataset_name)
self.client.add_dataset(scope=self.scope,
name=self.dataset_name,
rules=[{
......@@ -382,8 +383,8 @@ class DatasetInjector(object):
else:
# Register replica
logger.info("File %s already exits at RSE",
filemd['did_name'])
logger.debug("File %s already exits at RSE",
filemd['did_name'])
replica_for_api = convert_file_for_api(filemd)
if self.client.add_replicas(rse=self.rse_info['rse'],
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment