replication.init_replication(conn, base_url=args.config.REPLICATION_URL)
if args.update_functions:
LOG.warning("Create functions")
- refresh.create_functions(conn, args.config, args.data_dir,
+ refresh.create_functions(conn, args.config, args.sqllib_dir,
True, False)
conn.close()
return 0
LOG.warning("No new changes. Sleeping for %d sec.", recheck_interval)
time.sleep(recheck_interval)
- return state.value
-
@staticmethod
def run(args):
if args.check_for_updates:
return UpdateReplication._check_for_updates(args)
- return UpdateReplication._update(args)
+ UpdateReplication._update(args)
+ return 0