search

ApiLogicServer / ApiLogicServer-src

Create an executable project (API and Admin App) from a database or natural language prompt with 1 command, customize with declarative rules and Python in your IDE, containerize and deploy.
https://apilogicserver.github.io/Docs/
BSD 3-Clause "New" or "Revised" License
30 stars 5 forks source link

Kafka Producer has extra argument - Sample_ai fails in B2B Order #57

Closed valhuber closed 6 months ago

valhuber commented 6 months ago

Lost fix for integration/kafka/kafka_producer.py:

def send_kafka_message(logic_row: LogicRow, row_dict_mapper: RowDictMapper, 
                       kafka_topic: str, kafka_key: str, msg: str="",
                       json_root_name: str = ""):
    """ Send Kafka message regarding logic_row, mapped by row_dict_mapper

    * Typically called from declare_logic event

    Args:
        logic_row (LogicRow): root data to be sent
        row_dict_mapper (RowDictMapper): typically subclass of RowDictMapper, transforms row to dict
        kafka_topic (str): the kafka topic
        kafka_key (str): the kafka key
        msg (str, optional): string to log
        json_root_name (str, optional): json name for json payload root; default is logic_row.name
    """
    row_obj_dict = row_dict_mapper().row_to_dict(row = logic_row.row)

Fix in progress.

valhuber commented 6 months ago

Fixed in 10.04.01.