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.dev

All modeuls for developing and extending Fugue

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