Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
def handle(self, *args, **options):
if all(map(lambda x: x.get("CONN_MAX_AGE"), settings.DATABASES.values())):
self.stderr.write(
self.style.WARNING(
"WARNING: settings.CONN_MAX_AGE is not set to 0. "
"This may result in slots for database connections to "
"be exhausted."
)
)
subs = config.load_subscriptions_from_paths(
discover_subs_modules(), self.config.sub_prefix, self.config.filter_by
)
self.stdout.write(f"Configuring worker with {len(subs)} " f"subscription(s)...")
create_and_run(subs, self.config)
"defaults will be used.",
)
run_parser.add_argument(
"--settings",
"-s",
default=None,
required=False,
help="Settings file dot path. Ex. project.settings. "
"If none is supplied, Relé will attempt to autodiscover in the root path.",
)
args = parser.parse_args()
if args.command == "run":
settings, module_paths = discover.sub_modules(args.settings)
configuration = config.setup(settings.RELE if settings else None)
subs = config.load_subscriptions_from_paths(
module_paths, configuration.sub_prefix, configuration.filter_by
)
create_and_run(subs, configuration)