Parsers

flowtask.parsers

DataIntegration parsers.

Navigator can support parsing Tasks from JSON-format, YAML-format and more complex TOML format.

JSONParser

JSONParser(*args, **kwargs)

Bases: flowtask.parsers.base.TaskParser

__new__ builtin

__new__(*args, **kwargs)

Create and return a new object. See help(type) for accurate signature.

__reduce__ method descriptor

__reduce__()

JSONParser.reduce_cython(self)

__reduce_cython__ method descriptor

__reduce_cython__()

JSONParser.reduce_cython(self)

__setstate__ method descriptor

__setstate__()

JSONParser.setstate_cython(self, __pyx_state)

__setstate_cython__ method descriptor

__setstate_cython__(__pyx_state)

JSONParser.setstate_cython(self, __pyx_state)

parse async

parse(content)

JSONParser.parse(self, unicode content)

TOMLParser

TOMLParser(*args, **kwargs)

Bases: flowtask.parsers.base.TaskParser

__new__ builtin

__new__(*args, **kwargs)

Create and return a new object. See help(type) for accurate signature.

__reduce__ method descriptor

__reduce__()

TOMLParser.reduce_cython(self)

__reduce_cython__ method descriptor

__reduce_cython__()

TOMLParser.reduce_cython(self)

__setstate__ method descriptor

__setstate__()

TOMLParser.setstate_cython(self, __pyx_state)

__setstate_cython__ method descriptor

__setstate_cython__(__pyx_state)

TOMLParser.setstate_cython(self, __pyx_state)

parse async

parse(content)

TOMLParser.parse(self, unicode content)

YAMLParser

YAMLParser(*args, **kwargs)

Bases: flowtask.parsers.base.TaskParser

__new__ builtin

__new__(*args, **kwargs)

Create and return a new object. See help(type) for accurate signature.

__reduce__ method descriptor

__reduce__()

YAMLParser.reduce_cython(self)

__reduce_cython__ method descriptor

__reduce_cython__()

YAMLParser.reduce_cython(self)

__setstate__ method descriptor

__setstate__()

YAMLParser.setstate_cython(self, __pyx_state)

__setstate_cython__ method descriptor

__setstate_cython__(__pyx_state)

YAMLParser.setstate_cython(self, __pyx_state)

parse async

parse(content)

YAMLParser.parse(self, unicode content)

base

Parsing a Task File (abstract Method)

__doc__ module-attribute

__doc__ = '\nParsing a Task File (abstract Method)\n'

str(object='') -> str str(bytes_or_buffer[, encoding[, errors]]) -> str

Create a new string object from the given object. If encoding or errors is specified, then the object must expose a data buffer that will be decoded using the given encoding and error handler. Otherwise, returns the result of object.str() (if defined) or repr(object). encoding defaults to sys.getdefaultencoding(). errors defaults to 'strict'.

__file__ module-attribute

__file__ = '/home/jesuslara/proyectos/parallel/flowtask/flowtask/parsers/base.cpython-311-x86_64-linux-gnu.so'

str(object='') -> str str(bytes_or_buffer[, encoding[, errors]]) -> str

Create a new string object from the given object. If encoding or errors is specified, then the object must expose a data buffer that will be decoded using the given encoding and error handler. Otherwise, returns the result of object.str() (if defined) or repr(object). encoding defaults to sys.getdefaultencoding(). errors defaults to 'strict'.

__name__ module-attribute

__name__ = 'flowtask.parsers.base'

str(object='') -> str str(bytes_or_buffer[, encoding[, errors]]) -> str

Create a new string object from the given object. If encoding or errors is specified, then the object must expose a data buffer that will be decoded using the given encoding and error handler. Otherwise, returns the result of object.str() (if defined) or repr(object). encoding defaults to sys.getdefaultencoding(). errors defaults to 'strict'.

__package__ module-attribute

__package__ = 'flowtask.parsers'

str(object='') -> str str(bytes_or_buffer[, encoding[, errors]]) -> str

Create a new string object from the given object. If encoding or errors is specified, then the object must expose a data buffer that will be decoded using the given encoding and error handler. Otherwise, returns the result of object.str() (if defined) or repr(object). encoding defaults to sys.getdefaultencoding(). errors defaults to 'strict'.

__test__ module-attribute

__test__ = {}

dict() -> new empty dictionary dict(mapping) -> new dictionary initialized from a mapping object's (key, value) pairs dict(iterable) -> new dictionary initialized as if via: d = {} for k, v in iterable: d[k] = v dict(**kwargs) -> new dictionary initialized with the name=value pairs in the keyword argument list. For example: dict(one=1, two=2)

TaskParser

TaskParser(*args, **kwargs)

TaskParser(str file=None, str content=None)

__doc__ class-attribute

__doc__ = 'TaskParser(str file=None, str content=None)'

str(object='') -> str str(bytes_or_buffer[, encoding[, errors]]) -> str

Create a new string object from the given object. If encoding or errors is specified, then the object must expose a data buffer that will be decoded using the given encoding and error handler. Otherwise, returns the result of object.str() (if defined) or repr(object). encoding defaults to sys.getdefaultencoding(). errors defaults to 'strict'.

content property

content

content: object

filename property

filename

filename: object

__new__ builtin

__new__(*args, **kwargs)

Create and return a new object. See help(type) for accurate signature.

__reduce__ method descriptor

__reduce__()

TaskParser.reduce_cython(self)

__reduce_cython__ method descriptor

__reduce_cython__()

TaskParser.reduce_cython(self)

__setstate__ method descriptor

__setstate__()

TaskParser.setstate_cython(self, __pyx_state)

__setstate_cython__ method descriptor

__setstate_cython__(__pyx_state)

TaskParser.setstate_cython(self, __pyx_state)

open_file async

open_file()

TaskParser.open_file(self)

parse async

parse(content)

TaskParser.parse(self, str content)

run async

run()

TaskParser.run(self)

task_exists method descriptor

task_exists()

TaskParser.task_exists(self)

__pyx_unpickle_TaskParser method descriptor

__pyx_unpickle_TaskParser(__pyx_type, __pyx_checksum, __pyx_state)

__pyx_unpickle_TaskParser(__pyx_type, long __pyx_checksum, __pyx_state)

json

Parsing a Task from a JSON file.

__doc__ module-attribute

__doc__ = '\nParsing a Task from a JSON file.\n'

str(object='') -> str str(bytes_or_buffer[, encoding[, errors]]) -> str

Create a new string object from the given object. If encoding or errors is specified, then the object must expose a data buffer that will be decoded using the given encoding and error handler. Otherwise, returns the result of object.str() (if defined) or repr(object). encoding defaults to sys.getdefaultencoding(). errors defaults to 'strict'.

__file__ module-attribute

__file__ = '/home/jesuslara/proyectos/parallel/flowtask/flowtask/parsers/json.cpython-311-x86_64-linux-gnu.so'

str(object='') -> str str(bytes_or_buffer[, encoding[, errors]]) -> str

Create a new string object from the given object. If encoding or errors is specified, then the object must expose a data buffer that will be decoded using the given encoding and error handler. Otherwise, returns the result of object.str() (if defined) or repr(object). encoding defaults to sys.getdefaultencoding(). errors defaults to 'strict'.

__name__ module-attribute

__name__ = 'flowtask.parsers.json'

str(object='') -> str str(bytes_or_buffer[, encoding[, errors]]) -> str

Create a new string object from the given object. If encoding or errors is specified, then the object must expose a data buffer that will be decoded using the given encoding and error handler. Otherwise, returns the result of object.str() (if defined) or repr(object). encoding defaults to sys.getdefaultencoding(). errors defaults to 'strict'.

__package__ module-attribute

__package__ = 'flowtask.parsers'

str(object='') -> str str(bytes_or_buffer[, encoding[, errors]]) -> str

Create a new string object from the given object. If encoding or errors is specified, then the object must expose a data buffer that will be decoded using the given encoding and error handler. Otherwise, returns the result of object.str() (if defined) or repr(object). encoding defaults to sys.getdefaultencoding(). errors defaults to 'strict'.

__test__ module-attribute

__test__ = {}

dict() -> new empty dictionary dict(mapping) -> new dictionary initialized from a mapping object's (key, value) pairs dict(iterable) -> new dictionary initialized as if via: d = {} for k, v in iterable: d[k] = v dict(**kwargs) -> new dictionary initialized with the name=value pairs in the keyword argument list. For example: dict(one=1, two=2)

JSONParser

JSONParser(*args, **kwargs)

Bases: flowtask.parsers.base.TaskParser

__new__ builtin

__new__(*args, **kwargs)

Create and return a new object. See help(type) for accurate signature.

__reduce__ method descriptor

__reduce__()

JSONParser.reduce_cython(self)

__reduce_cython__ method descriptor

__reduce_cython__()

JSONParser.reduce_cython(self)

__setstate__ method descriptor

__setstate__()

JSONParser.setstate_cython(self, __pyx_state)

__setstate_cython__ method descriptor

__setstate_cython__(__pyx_state)

JSONParser.setstate_cython(self, __pyx_state)

parse async

parse(content)

JSONParser.parse(self, unicode content)

__pyx_unpickle_JSONParser method descriptor

__pyx_unpickle_JSONParser(__pyx_type, __pyx_checksum, __pyx_state)

__pyx_unpickle_JSONParser(__pyx_type, long __pyx_checksum, __pyx_state)

toml

Parsing a Task from a TOML file.

__doc__ module-attribute

__doc__ = '\nParsing a Task from a TOML file.\n'

str(object='') -> str str(bytes_or_buffer[, encoding[, errors]]) -> str

Create a new string object from the given object. If encoding or errors is specified, then the object must expose a data buffer that will be decoded using the given encoding and error handler. Otherwise, returns the result of object.str() (if defined) or repr(object). encoding defaults to sys.getdefaultencoding(). errors defaults to 'strict'.

__file__ module-attribute

__file__ = '/home/jesuslara/proyectos/parallel/flowtask/flowtask/parsers/toml.cpython-311-x86_64-linux-gnu.so'

str(object='') -> str str(bytes_or_buffer[, encoding[, errors]]) -> str

Create a new string object from the given object. If encoding or errors is specified, then the object must expose a data buffer that will be decoded using the given encoding and error handler. Otherwise, returns the result of object.str() (if defined) or repr(object). encoding defaults to sys.getdefaultencoding(). errors defaults to 'strict'.

__name__ module-attribute

__name__ = 'flowtask.parsers.toml'

str(object='') -> str str(bytes_or_buffer[, encoding[, errors]]) -> str

Create a new string object from the given object. If encoding or errors is specified, then the object must expose a data buffer that will be decoded using the given encoding and error handler. Otherwise, returns the result of object.str() (if defined) or repr(object). encoding defaults to sys.getdefaultencoding(). errors defaults to 'strict'.

__package__ module-attribute

__package__ = 'flowtask.parsers'

str(object='') -> str str(bytes_or_buffer[, encoding[, errors]]) -> str

Create a new string object from the given object. If encoding or errors is specified, then the object must expose a data buffer that will be decoded using the given encoding and error handler. Otherwise, returns the result of object.str() (if defined) or repr(object). encoding defaults to sys.getdefaultencoding(). errors defaults to 'strict'.

__test__ module-attribute

__test__ = {}

dict() -> new empty dictionary dict(mapping) -> new dictionary initialized from a mapping object's (key, value) pairs dict(iterable) -> new dictionary initialized as if via: d = {} for k, v in iterable: d[k] = v dict(**kwargs) -> new dictionary initialized with the name=value pairs in the keyword argument list. For example: dict(one=1, two=2)

TOMLParser

TOMLParser(*args, **kwargs)

Bases: flowtask.parsers.base.TaskParser

__new__ builtin

__new__(*args, **kwargs)

Create and return a new object. See help(type) for accurate signature.

__reduce__ method descriptor

__reduce__()

TOMLParser.reduce_cython(self)

__reduce_cython__ method descriptor

__reduce_cython__()

TOMLParser.reduce_cython(self)

__setstate__ method descriptor

__setstate__()

TOMLParser.setstate_cython(self, __pyx_state)

__setstate_cython__ method descriptor

__setstate_cython__(__pyx_state)

TOMLParser.setstate_cython(self, __pyx_state)

parse async

parse(content)

TOMLParser.parse(self, unicode content)

__pyx_unpickle_TOMLParser method descriptor

__pyx_unpickle_TOMLParser(__pyx_type, __pyx_checksum, __pyx_state)

__pyx_unpickle_TOMLParser(__pyx_type, long __pyx_checksum, __pyx_state)