async def requirement_update(ns={}):
    product_category = ns.get('product_category')
    company_type = ns.get('company_type')
    if product_category:
        ns['product_category'] = json.dumps(product_category) if isinstance(product_category, list) else product_category
    if company_type:
        ns['company_type'] = json.dumps(company_type) if isinstance(company_type, list) else company_type
    db = DBPools()
    async with db.sqlorContext('kboss') as sor:
        try:
            await sor.U('user_publish_requirement', ns)
            return {
                'status': True,
                'msg': 'Requirement updated successfully'
            }
        except Exception as e:
            return {
                'status': False,
                'msg': 'Failed to update requirement, %s' % str(e)
            }

ret = await requirement_update(params_kw)
return ret