Marmelator/pyinfra
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 36 Wiki Activity

topological sorting of definitions by caller hierarchy

Browse Source
This commit is contained in:
Matthias Bisping 2022-06-27 10:55:47 +02:00
parent 94254e1681
commit af0892a899
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
pyinfra/component_factory.py
View File

@ -60,6 +60,13 @@ class ComponentFactory:
def get_queue_manager(self): def get_queue_manager(self):
return PikaQueueManager(self.config.rabbitmq.queues.input, self.config.rabbitmq.queues.output) return PikaQueueManager(self.config.rabbitmq.queues.input, self.config.rabbitmq.queues.output)
@staticmethod
@lru_cache(maxsize=None)
def get_pipeline(endpoint):
return ClientPipeline(
RestPacker(), RestDispatcher(endpoint), RestReceiver(), rcompose(RestPickupStreamer(), RestReceiver())
)
@lru_cache(maxsize=None) @lru_cache(maxsize=None)
def get_storage(self): def get_storage(self):
return storages.get_storage(self.config.storage.backend) return storages.get_storage(self.config.storage.backend)
@ -100,10 +107,3 @@ class ComponentFactory:
bucket_name=parse_disjunction_string(self.config.storage.bucket), bucket_name=parse_disjunction_string(self.config.storage.bucket),
file_descriptor_manager=self.get_file_descriptor_manager(), file_descriptor_manager=self.get_file_descriptor_manager(),
) )
@staticmethod
@lru_cache(maxsize=None)
def get_pipeline(endpoint):
return ClientPipeline(
RestPacker(), RestDispatcher(endpoint), RestReceiver(), rcompose(RestPickupStreamer(), RestReceiver())
)