diff options
| author | Wojtek Kosior <koszko@koszko.org> | 2022-09-27 12:18:36 +0200 |
|---|---|---|
| committer | Wojtek Kosior <koszko@koszko.org> | 2022-09-29 10:47:17 +0200 |
| commit | 8c9c79921538fef769367728199d54b2013b7f0f (patch) | |
| tree | 78558259b462a19775e07cf6428977621f0081f8 /src/hydrilla/proxy/state_impl/payloads.py | |
| parent | 05f1f813fa5dad4e9794dcccb0ea24e75a215029 (diff) | |
| download | haketilo-hydrilla-8c9c79921538fef769367728199d54b2013b7f0f.tar.gz haketilo-hydrilla-8c9c79921538fef769367728199d54b2013b7f0f.zip | |
[proxy] move payload dependencies installation logic to ConcreteMappingVersion class
Diffstat (limited to 'src/hydrilla/proxy/state_impl/payloads.py')
| -rw-r--r-- | src/hydrilla/proxy/state_impl/payloads.py | 37 |
1 files changed, 4 insertions, 33 deletions
diff --git a/src/hydrilla/proxy/state_impl/payloads.py b/src/hydrilla/proxy/state_impl/payloads.py index ffd0ab3..74b8121 100644 --- a/src/hydrilla/proxy/state_impl/payloads.py +++ b/src/hydrilla/proxy/state_impl/payloads.py @@ -174,41 +174,12 @@ class ConcretePayloadRef(st.PayloadRef): (mapping_version_id,), = rows - cursor.execute( - ''' - UPDATE - item_versions - SET - installed = 'I' - WHERE - item_version_id = ?; - ''', - (mapping_version_id,) - ) - - cursor.execute( - ''' - WITH depended_resource_ids AS ( - SELECT - rdd.resource_item_id - FROM - payloads AS p - JOIN resolved_depended_resources AS rdd - USING (payload_id) - WHERE - payload_id = ? - ) - UPDATE - item_versions - SET - installed = 'I' - WHERE - item_version_id IN depended_resource_ids; - ''', - (self.id,) + mapping_version_ref = items.ConcreteMappingVersionRef( + id = str(mapping_version_id), + state = self.state ) - self.state.pull_missing_files() + mapping_version_ref.ensure_depended_items_installed() def get_script_paths(self) \ -> t.Iterable[t.Sequence[str]]: |