luigi.contrib.redis_store module

class luigi.contrib.redis_store.RedisTarget(host, port, db, update_id, password=None, socket_timeout=None, expire=None)

Bases: Target

Target for a resource in Redis.

Parameters:

• host (str) – Redis server host

• port (int) – Redis server port

• db (int) – database index

• update_id (str) – an identifier for this data hash

• password (str) – a password to connect to the redis server

• socket_timeout (int) – client socket timeout

• expire (int) – timeout before the target is deleted

marker_prefix = Parameter (defaults to luigi)

marker_key()

Generate a key for the indicator hash.

touch()

Mark this update as complete.

We index the parameters update_id and date.

exists()

Test, if this task has been run.