Commit 5941b321 authored by Andrey Vertiprahov's avatar Andrey Vertiprahov
Browse files

Set DatastreamClient filter_policy to delete on Collectors.

parent af2c47ff
Pipeline #34263 passed with stages
in 25 minutes and 29 seconds
......@@ -98,6 +98,7 @@ class PingService(FastAPIService):
"shard(%d,%d)" % (self.slot_number, self.total_slots),
],
block=True,
filter_policy="delete",
)
except NOCError as e:
self.logger.info("Failed to get object mappings: %s", e)
......
......@@ -133,6 +133,7 @@ class SyslogCollectorService(TornadoService):
limit=config.syslogcollector.ds_limit,
filters=["pool(%s)" % config.pool],
block=True,
filter_policy="delete",
)
except NOCError as e:
self.logger.info("Failed to get object mappings: %s", e)
......
......@@ -108,6 +108,7 @@ class TrapCollectorService(TornadoService):
limit=config.trapcollector.ds_limit,
filters=["pool(%s)" % config.pool],
block=True,
filter_policy="delete",
)
except NOCError as e:
self.logger.info("Failed to get object mappings: %s", e)
......
Supports Markdown
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