Minor refactoring; radmc parameters mapping in constants.

import logging

import sys

import astropy.units

import sqlalchemy

import yaml

import numpy as np

import shutil

import urllib.request

import base64

import json

import tarfile

import sqlalchemy as sqla

from sqlalchemy.orm import Session

from sqlalchemy.dialects.postgresql import insert

    return frequency.to(output_units, equivalencies=u.spectral())

def get_pg_engine(logger: logging.Logger) -> sqlalchemy.engine.Engine:

def get_pg_engine(logger: logging.Logger) -> sqla.engine.Engine:

    """

    Return the SQLAlchemy engine, given the credentials in the external file

    :param logger: the logger to use

    """

    credentials = get_credentials(logger=logger,

                                  credentials_filename=os.path.join('credentials', 'db_credentials.yml'))

    url = f"postgresql://{credentials['DB_USER']}:{credentials['DB_PASS']}@{credentials['DB_HOST']}:{credentials['DB_PORT']}/{credentials['DB_NAME']}"

    engine = sqlalchemy.create_engine(url)

    url = f'postgresql://{credentials["DB_USER"]}:{credentials["DB_PASS"]}@{credentials["DB_HOST"]}:{credentials["DB_PORT"]}/{credentials["DB_NAME"]}'

    engine = sqla.create_engine(url)

    return engine

    'iline': 'iline',

    'width_kms': 'widthkms',

    'nchannels': 'linenlam',

    'npix': 'npix'

    'npix': 'npix',

    'image_size_pc': 'sizepc',

    'threads': 'setthreads'

}

aggregation_function_mapping = {