(self, db_alias)
return None if shard_count is None else completed_count == shard_count
Mark shard complete
        :returns: True if all shards are complete else false; None if shard
        count is not set.
Mark shard complete
        :returns: True if all shards are complete else false; None if shard
        count is not set.
Mark shard complete : returns : True if all shards are complete else false ; None if shard count is not set .
def mark_shard_complete(self, db_alias):
        """Mark shard complete
        :returns: True if all shards are complete else false; None if shard
        count is not set.
        """
        shard_count = self.client.get(self.shard_count_key)
        pipe = self.client.client.get_client().pipeline()
        pipe.sadd(self.completed_shards_key, db_alias)
        pipe.scard(self.completed_shards_key)
        ignore, completed_count = pipe.execute()
        self.client.expire(self.shard_count_key, self.key_expiry)
        self.client.expire(self.completed_shards_key, self.key_expiry)
        return None if shard_count is None else completed_count == shard_count
def mark_shard_complete ( self , db_alias ) : shard_count = self . client . get ( self . shard_count_key ) pipe = self . client . client . get_client ( ) . pipeline ( ) pipe . sadd ( self . completed_shards_key , db_alias ) pipe . scard ( self . completed_shards_key ) ignore , completed_count = pipe . execute ( ) self . client . expire ( self . shard_count_key , self . key_expiry ) self . client . expire ( self . completed_shards_key , self . key_expiry ) return None if shard_count is None else completed_count == shard_count