Skip to content

Commit

Permalink
Added default ports to all the other data components
Browse files Browse the repository at this point in the history
  • Loading branch information
james-strauss-uwa committed Jun 23, 2022
1 parent 651e480 commit 9f1f50e
Show file tree
Hide file tree
Showing 3 changed files with 19 additions and 4 deletions.
20 changes: 16 additions & 4 deletions daliuge-engine/dlg/drop.py
Original file line number Diff line number Diff line change
Expand Up @@ -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):
"""
Expand Down Expand Up @@ -1701,10 +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/
# \~English Dummy input port
# @param[out] port/dummy dummy/Complex/
# \~English Dummy output port
# @param[in] port/dummy dummy/Complex/Dummy input port
# @param[out] port/dummy dummy/Complex/Dummy output port
# @par EAGLE_END
class NgasDROP(DataDROP):
"""
Expand Down Expand Up @@ -1823,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):
"""
Expand Down Expand Up @@ -1879,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):
"""
Expand Down Expand Up @@ -1929,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):
"""
Expand Down Expand Up @@ -1969,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):
"""
Expand Down Expand Up @@ -2196,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):
"""
Expand Down Expand Up @@ -2246,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):
"""
Expand Down
1 change: 1 addition & 0 deletions daliuge-engine/dlg/environmentvar_drop.py
Original file line number Diff line number Diff line change
Expand Up @@ -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):
"""
Expand Down
2 changes: 2 additions & 0 deletions daliuge-engine/dlg/s3_drop.py
Original file line number Diff line number Diff line change
Expand Up @@ -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):
"""
Expand Down

0 comments on commit 9f1f50e

Please sign in to comment.