nodes

count_source(limit: int = 1000, start: int = 0) → Generator[Annotated[int, Name(name=index)], None, None][source]
letter_source() → Generator[Annotated[str, Name(name=letter)]][source]
word_source() → Generator[Annotated[str, Name(name=word)]][source]
multi_words_source(n: int) → Generator[Annotated[list[str], Name(name=multi_words)]][source]
sporadic_word(every: int = 3) → Generator[Annotated[str, Name(name=word)] | None, None, None][source]
word_counts() → Generator[tuple[Annotated[str, Name(name=word)], Annotated[list[int], Name(name=counts)]]][source]
multiply(left: int, right: int = 2) → int[source]

Return value purposely unnamed, to be used as {nodename}.value

divide(numerator: int, denominator: int = 5) → Annotated[float, Name(name=ratio)][source]
concat(strings: list[str]) → str[source]
exclaim(string: str) → str[source]
repeat(string: str, times: int) → str[source]
dictify(key: str, items: list[Any]) → dict[str, Any][source]
error(value: Any) → None[source]
pydantic model CountSource[source]

Show JSON schema
{
   "title": "CountSource",
   "type": "object",
   "properties": {
      "id": {
         "title": "Id",
         "type": "string"
      },
      "spec": {
         "anyOf": [
            {
               "$ref": "#/$defs/NodeSpecification"
            },
            {
               "type": "null"
            }
         ],
         "default": null
      },
      "enabled": {
         "default": true,
         "title": "Enabled",
         "type": "boolean"
      },
      "limit": {
         "default": 1000,
         "title": "Limit",
         "type": "integer"
      },
      "start": {
         "default": 0,
         "title": "Start",
         "type": "integer"
      }
   },
   "$defs": {
      "NodeSpecification": {
         "description": "Specification for a single processing node within a tube .yaml file.",
         "properties": {
            "type": {
               "title": "Type",
               "type": "string"
            },
            "id": {
               "title": "Id",
               "type": "string"
            },
            "depends": {
               "anyOf": [
                  {
                     "items": {
                        "anyOf": [
                           {
                              "type": "string"
                           },
                           {
                              "additionalProperties": {
                                 "type": "string"
                              },
                              "maxProperties": 1,
                              "minProperties": 1,
                              "type": "object"
                           }
                        ]
                     },
                     "type": "array"
                  },
                  {
                     "type": "string"
                  },
                  {
                     "type": "null"
                  }
               ],
               "default": null,
               "title": "Depends"
            },
            "params": {
               "anyOf": [
                  {
                     "additionalProperties": true,
                     "type": "object"
                  },
                  {
                     "type": "null"
                  }
               ],
               "default": null,
               "title": "Params"
            },
            "enabled": {
               "default": true,
               "title": "Enabled",
               "type": "boolean"
            }
         },
         "required": [
            "type",
            "id"
         ],
         "title": "NodeSpecification",
         "type": "object"
      }
   },
   "additionalProperties": false,
   "required": [
      "id"
   ]
}

Config:

  • extra: str = forbid

Fields:
field limit: int = 1000
field start: int = 0
model_post_init(_Node__context: Any) → None

See docstring of process() for description of post init wrapping of generators

process() → Generator[Annotated[int, Name(name=index)], None, None][source]
pydantic model UnannotatedGenerator[source]

Show JSON schema
{
   "title": "UnannotatedGenerator",
   "type": "object",
   "properties": {
      "id": {
         "title": "Id",
         "type": "string"
      },
      "spec": {
         "anyOf": [
            {
               "$ref": "#/$defs/NodeSpecification"
            },
            {
               "type": "null"
            }
         ],
         "default": null
      },
      "enabled": {
         "default": true,
         "title": "Enabled",
         "type": "boolean"
      },
      "limit": {
         "default": 1000,
         "title": "Limit",
         "type": "integer"
      },
      "start": {
         "default": 0,
         "title": "Start",
         "type": "integer"
      }
   },
   "$defs": {
      "NodeSpecification": {
         "description": "Specification for a single processing node within a tube .yaml file.",
         "properties": {
            "type": {
               "title": "Type",
               "type": "string"
            },
            "id": {
               "title": "Id",
               "type": "string"
            },
            "depends": {
               "anyOf": [
                  {
                     "items": {
                        "anyOf": [
                           {
                              "type": "string"
                           },
                           {
                              "additionalProperties": {
                                 "type": "string"
                              },
                              "maxProperties": 1,
                              "minProperties": 1,
                              "type": "object"
                           }
                        ]
                     },
                     "type": "array"
                  },
                  {
                     "type": "string"
                  },
                  {
                     "type": "null"
                  }
               ],
               "default": null,
               "title": "Depends"
            },
            "params": {
               "anyOf": [
                  {
                     "additionalProperties": true,
                     "type": "object"
                  },
                  {
                     "type": "null"
                  }
               ],
               "default": null,
               "title": "Params"
            },
            "enabled": {
               "default": true,
               "title": "Enabled",
               "type": "boolean"
            }
         },
         "required": [
            "type",
            "id"
         ],
         "title": "NodeSpecification",
         "type": "object"
      }
   },
   "additionalProperties": false,
   "required": [
      "id"
   ]
}

Config:

  • extra: str = forbid

Fields:
field limit: int = 1000
field start: int = 0
model_post_init(_Node__context: Any) → None

See docstring of process() for description of post init wrapping of generators

process()[source]
pydantic model Multiply[source]

Show JSON schema
{
   "title": "Multiply",
   "type": "object",
   "properties": {
      "id": {
         "title": "Id",
         "type": "string"
      },
      "spec": {
         "anyOf": [
            {
               "$ref": "#/$defs/NodeSpecification"
            },
            {
               "type": "null"
            }
         ],
         "default": null
      },
      "enabled": {
         "default": true,
         "title": "Enabled",
         "type": "boolean"
      }
   },
   "$defs": {
      "NodeSpecification": {
         "description": "Specification for a single processing node within a tube .yaml file.",
         "properties": {
            "type": {
               "title": "Type",
               "type": "string"
            },
            "id": {
               "title": "Id",
               "type": "string"
            },
            "depends": {
               "anyOf": [
                  {
                     "items": {
                        "anyOf": [
                           {
                              "type": "string"
                           },
                           {
                              "additionalProperties": {
                                 "type": "string"
                              },
                              "maxProperties": 1,
                              "minProperties": 1,
                              "type": "object"
                           }
                        ]
                     },
                     "type": "array"
                  },
                  {
                     "type": "string"
                  },
                  {
                     "type": "null"
                  }
               ],
               "default": null,
               "title": "Depends"
            },
            "params": {
               "anyOf": [
                  {
                     "additionalProperties": true,
                     "type": "object"
                  },
                  {
                     "type": "null"
                  }
               ],
               "default": null,
               "title": "Params"
            },
            "enabled": {
               "default": true,
               "title": "Enabled",
               "type": "boolean"
            }
         },
         "required": [
            "type",
            "id"
         ],
         "title": "NodeSpecification",
         "type": "object"
      }
   },
   "additionalProperties": false,
   "required": [
      "id"
   ]
}

Config:

  • extra: str = forbid

Fields:

model_post_init(_Node__context: Any) → None

See docstring of process() for description of post init wrapping of generators

process(left: int, right: int = 2) → Annotated[int, Name(name=product)][source]
class VolumeProcess(height: int = 2)[source]
process(width: int, depth: int) → Annotated[int, Name(name=volume)][source]
class Volume(height: int = 2)[source]
volume(width: int, depth: int) → Annotated[int, Name(name=volume)][source]
class Now[source]
print(prefix: str = 'Now: ') → Annotated[str, Name(name=timestamp)][source]
array_add_to_left(left: DataArray, right: DataArray) → DataArray[source]
class CountSourceDecor(start: int = 0)[source]
process() → Generator[Annotated[int, Name(name=count)], None, None][source]
input_party(one: int, two: float, three: str, four: bool, five: list, six: dict, seven: set) → Annotated[bool, Name(name=works)][source]
read_db(conn: Connection) → Annotated[tuple[int, str], Name(name=payload)][source]