Merge pull request #184 from ICRAR/liu-262-data-component-default-ports

Liu 262 data component default ports
ICRAR · Jun 24, 2022 · 1576295 · 1576295
2 parents 6127046 + 9f1f50e
commit 1576295
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 0 deletions.
diff --git a/daliuge-engine/dlg/drop.py b/daliuge-engine/dlg/drop.py
@@ -1501,6 +1501,8 @@ def dataURL(self) -> str:
 #     \~English Path to the file for this node
 # @param[in] cparam/dirname Directory name//String/readwrite/False//False/
 #     \~English Path to the file for this node
+# @param[in] port/dummy dummy/Complex/Dummy input port
+# @param[out] port/dummy dummy/Complex/Dummy output port
 # @par EAGLE_END
 class FileDROP(DataDROP, PathBasedDrop):
     """
@@ -1701,6 +1703,8 @@ def generate_reproduce_data(self):
 #     \~English Mime-type to be used for archiving
 # @param[in] cparam/ngasTimeout NGAS timeout/2/Integer/readwrite/False//False/
 #     \~English Timeout for receiving responses for NGAS
+# @param[in] port/dummy dummy/Complex/Dummy input port
+# @param[out] port/dummy dummy/Complex/Dummy output port
 # @par EAGLE_END
 class NgasDROP(DataDROP):
     """
@@ -1819,6 +1823,8 @@ def generate_reproduce_data(self):
 #     \~English Estimated size of the data contained in this node
 # @param[in] cparam/group_end Group end/False/Boolean/readwrite/False//False/
 #     \~English Is this node the end of a group?
+# @param[in] port/dummy dummy/Complex/Dummy input port
+# @param[out] port/dummy dummy/Complex/Dummy output port
 # @par EAGLE_END
 class InMemoryDROP(DataDROP):
     """
@@ -1875,6 +1881,8 @@ def generate_reproduce_data(self):
 #     \~English Estimated size of the data contained in this node
 # @param[in] cparam/group_end Group end/False/Boolean/readwrite/False//False/
 #     \~English Is this node the end of a group?
+# @param[in] port/dummy dummy/Complex/Dummy input port
+# @param[out] port/dummy dummy/Complex/Dummy output port
 # @par EAGLE_END
 class SharedMemoryDROP(DataDROP):
     """
@@ -1925,6 +1933,8 @@ def dataURL(self) -> str:
 #     \~English This never stores any data
 # @param[in] cparam/group_end Group end/False/Boolean/readwrite/False//False/
 #     \~English Is this node the end of a group?
+# @param[in] port/dummy dummy/Complex/Dummy input port
+# @param[out] port/dummy dummy/Complex/Dummy output port
 # @par EAGLE_END
 class NullDROP(DataDROP):
     """
@@ -1965,6 +1975,8 @@ class EndDROP(NullDROP):
 #     \~English Condition for SELECT. For this the WHERE statement must be written using the "{X}" or "{}" placeholders
 # @param[in] cparam/selectVals values for WHERE//Json/readwrite/False//False/
 #     \~English Values for the WHERE statement
+# @param[in] port/dummy dummy/Complex/Dummy input port
+# @param[out] port/dummy dummy/Complex/Dummy output port
 # @par EAGLE_END
 class RDBMSDrop(DataDROP):
     """
@@ -2192,6 +2204,8 @@ def exists(self):
 #     \~English PlasmaId of the object for all compute nodes
 # @param[in] cparam/use_staging Use Staging/False/Boolean/readwrite/False//False/
 #     \~English Enables writing to a dynamically resizeable staging buffer
+# @param[in] port/dummy dummy/Complex/Dummy input port
+# @param[out] port/dummy dummy/Complex/Dummy output port
 # @par EAGLE_END
 class PlasmaDROP(DataDROP):
     """
@@ -2242,6 +2256,8 @@ def dataURL(self) -> str:
 #     \~English PlasmaId of the object for all compute nodes
 # @param[in] cparam/flight_path Flight Path//String/readwrite/False//False/
 #     \~English IP and flight port of the drop owner
+# @param[in] port/dummy dummy/Complex/Dummy input port
+# @param[out] port/dummy dummy/Complex/Dummy output port
 # @par EAGLE_END
 class PlasmaFlightDROP(DataDROP):
     """

diff --git a/daliuge-engine/dlg/environmentvar_drop.py b/daliuge-engine/dlg/environmentvar_drop.py
@@ -66,6 +66,7 @@ def _filter_parameters(parameters: dict):
 # @par EAGLE_START
 # @param category EnvironmentVariables
 # @param tag daliuge
+# @param[out] port/dummy dummy/Complex/Dummy output port
 # @par EAGLE_END
 class EnvironmentVarDROP(AbstractDROP, KeyValueDROP):
     """

diff --git a/daliuge-engine/dlg/s3_drop.py b/daliuge-engine/dlg/s3_drop.py
@@ -46,6 +46,8 @@
 #     \~English The S3 Object
 # @param[in] cparam/profile_name Profile Name//String/readwrite/False//False/
 #     \~English The S3 Profile
+# @param[in] port/dummy dummy/Complex/Dummy input port
+# @param[out] port/dummy dummy/Complex/Dummy output port
 # @par EAGLE_END
 class S3DROP(AbstractDROP):
     """