def __init__(self,
                 table,
                 postgres_database,
                 insert_query,
                 max_errors=None,
                 replace_invalid_char=None,
                 **kwargs):
        super(LoadPostgresStep, self).__init__(**kwargs)

        region = POSTGRES_CONFIG['REGION']
        rds_instance_id = POSTGRES_CONFIG['RDS_INSTANCE_ID']
        user = POSTGRES_CONFIG['USERNAME']
        password = POSTGRES_CONFIG['PASSWORD']
        database_node = self.create_pipeline_object(
                    object_class=PostgresDatabase,
                    region=region,
                    rds_instance_id=rds_instance_id,
                    username=user,
                    password=password,
        )

        # Create output node
        self._output = self.create_pipeline_object(
            object_class=PostgresNode,
            schedule=self.schedule,
            database=database_node,
            table=table,
            username=user,
            password=password,
            select_query=None,
            insert_query=insert_query,
            host=rds_instance_id,
        )

        self.create_pipeline_object(
            object_class=CopyActivity,
            schedule=self.schedule,
            resource=self.resource,
            input_node=self.input,
            output_node=self.output,
            depends_on=self.depends_on,
            max_retries=self.max_retries,
        )
Compile this SQL expression.
dataset/ETHPy150Open coursera/dataduct/dataduct/steps/load_postgres.py/LoadPostgresStep.__init__--crossover with--dataset/ETHPy150Open goFrendiAsgard/kokoropy/kokoropy/packages/sqlalchemy/sql/elements.py/ClauseElement.compile