diff --git a/backfiller/backfiller/main.py b/backfiller/backfiller/main.py index c66a78d..837c3df 100644 --- a/backfiller/backfiller/main.py +++ b/backfiller/backfiller/main.py @@ -129,12 +129,6 @@ def get_remote_segment(base_dir, node, stream, variant, hour, missing_segment, segments_backfilled.labels(remote=node, stream=stream, variant=variant, hour=hour).inc() -def last_hours(n_hours=3): - """Return of a list of the last n_hours in descending order.""" - now = datetime.datetime.utcnow() - return [(now - i * datetime.timedelta(hours=1)).strftime(HOUR_FMT) for i in range(n_hours)] - - def list_hours(node, stream, variants, start=None): """Return a list of all available hours from a node. @@ -169,7 +163,7 @@ class BackfillerManager(object): NODE_INTERVAL = 300 #seconds between updating list of nodes - def __init__(self, base_dir, stream, variants, static_nodes=[], start, run_once=False): + def __init__(self, base_dir, stream, variants, static_nodes=[], start=None, run_once=False): """Constructor for BackfillerManager. Creates a manager for a given stream with specified variants. If static_nodes is None, manager""" diff --git a/docker-compose.jsonnet b/docker-compose.jsonnet index 49f8adf..c0cc582 100644 --- a/docker-compose.jsonnet +++ b/docker-compose.jsonnet @@ -82,7 +82,7 @@ command: [ "--stream", $.channel, "-v", std.join(",", $.qualities), - "--nodes", std.join(",", $.peers), + "--static-nodes", std.join(",", $.peers), "--backdoor-port", std.toString($.backdoor_port), ], // Mount the segments directory at /mnt