fugue#

fugue.api#

fugue.constants#

fugue.constants.register_global_conf(conf, on_dup=0)[source]#

Register global Fugue configs that can be picked up by any Fugue execution engines as the base configs.

Parameters
Return type

None

Note

When using ParamDict.THROW or on_dup, it’s transactional. If any key in conf is already in global config and the value is different from the new value, then ValueError will be thrown.

Examples

from fugue import register_global_conf, NativeExecutionEngine

register_global_conf({"my.value",1})

engine = NativeExecutionEngine()
assert 1 == engine.conf["my.value"]

engine = NativeExecutionEngine({"my.value",2})
assert 2 == engine.conf["my.value"]

fugue.exceptions#

exception fugue.exceptions.FugueBug[source]#

Bases: FugueError

Fugue internal bug

exception fugue.exceptions.FugueDataFrameError[source]#

Bases: FugueError

Fugue dataframe related error

exception fugue.exceptions.FugueDataFrameInitError[source]#

Bases: FugueDataFrameError

Fugue dataframe initialization error

exception fugue.exceptions.FugueDataFrameOperationError[source]#

Bases: FugueDataFrameError

Fugue dataframe invalid operation

exception fugue.exceptions.FugueDatasetEmptyError[source]#

Bases: FugueDataFrameError

Fugue dataframe is empty

exception fugue.exceptions.FugueError[source]#

Bases: Exception

Fugue exceptions

exception fugue.exceptions.FugueInterfacelessError[source]#

Bases: FugueWorkflowCompileError

Fugue interfaceless exceptions

exception fugue.exceptions.FugueInvalidOperation[source]#

Bases: FugueError

Invalid operation on the Fugue framework

exception fugue.exceptions.FuguePluginsRegistrationError[source]#

Bases: FugueError

Fugue plugins registration error

exception fugue.exceptions.FugueSQLError[source]#

Bases: FugueWorkflowCompileError

Fugue SQL error

exception fugue.exceptions.FugueSQLRuntimeError[source]#

Bases: FugueWorkflowRuntimeError

Fugue SQL runtime error

exception fugue.exceptions.FugueSQLSyntaxError[source]#

Bases: FugueSQLError

Fugue SQL syntax error

exception fugue.exceptions.FugueWorkflowCompileError[source]#

Bases: FugueWorkflowError

Fugue workflow compile time error

exception fugue.exceptions.FugueWorkflowCompileValidationError[source]#

Bases: FugueWorkflowCompileError

Fugue workflow compile time validation error

exception fugue.exceptions.FugueWorkflowError[source]#

Bases: FugueError

Fugue workflow exceptions

exception fugue.exceptions.FugueWorkflowRuntimeError[source]#

Bases: FugueWorkflowError

Fugue workflow compile time error

exception fugue.exceptions.FugueWorkflowRuntimeValidationError[source]#

Bases: FugueWorkflowRuntimeError

Fugue workflow runtime validation error

fugue.plugins#

fugue.registry#