Adds information on staged source

docs/common/sources.rst

@@ -1,7 +1,7 @@
 Supported Sources
 ------------------
 
-The tooling supports the `KojiSource`_ and `ErrataSource`_ from ``pushsource``.
+The tooling supports the `KojiSource`_ , `ErrataSource`_ , and `StagedSource`_ from ``pushsource``.
 
 All the VM images in the given source path will be uploaded
 to the corresponding cloud provider and published to its marketplace.
@@ -17,3 +17,4 @@ The expected parameter for the VM images is ``vmi_build``:
 
 .. _KojiSource: https://release-engineering.github.io/pushsource/sources/koji.html#accessing-virtual-machine-images
 .. _ErrataSource: https://release-engineering.github.io/pushsource/sources/errata.html
+.. _StagedSource: https://release-engineering.github.io/pushsource/sources/staged.html

requirements.txt

@@ -2,7 +2,7 @@ cloudimg>=1.14.0
 pubtools>=1.3.0
 more_executors>=2.11.4
 pushcollector>=1.3.0
-pushsource>=2.47.2
+pushsource>=2.48.0
 strenum>=0.4.15
 starmap-client>=2.1.0
 cloudpub>=1.2.1

src/pubtools/_marketplacesvm/tasks/push/items/starmap.py

@@ -111,7 +111,7 @@ def _update_push_item_properties(
 
     def _map_push_item(self, destinations: List[Destination]) -> VMIPushItem:
         """Return the wrapped push item with the missing attributes set."""
-        if self.push_item.dest:  # If it has destinations it means we already mapped its properties
+        if self.push_item.dest and "starmap" not in self.push_item.dest:  # If it has destinations it means we already mapped its properties
             # Just update the destinations for the marketplace and return
             self.push_item = evolve(self.push_item, dest=destinations)
             return self.push_item

tests/push/conftest.py

@@ -58,7 +58,7 @@ def vhd_push_item(release_params: Dict[str, Any], push_item_params: Dict[str, st
 def ami_push_item(release_params: Dict[str, Any], push_item_params: Dict[str, str]) -> AmiPushItem:
     """Return a minimal AmiPushItem."""
     release = AmiRelease(**release_params)
-    push_item_params.update({"name": "ami_pushitem", "release": release})
+    push_item_params.update({"name": "ami_pushitem", "release": release, "dest": ["starmap"]})
     return AmiPushItem(**push_item_params)