luigi.contrib.redis_store module

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

Bases: luigi.target.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.