def main()

in demo_deployment/firestore_crud.py [0:0]


def main(args, loglevel):
    logging.basicConfig(format="%(levelname)s: %(message)s", level=loglevel)
    db = firestore.Client(project=args.gcp_project, database=DEFAULT_DATABASE_NAME)
    if hasattr(args, 'workflow_properties'):
        print(args.workflow_properties)
        #workflow_props = json.loads(args.workflow_properties)
        workflow_props = args.workflow_properties
    if args.operation_type in('CREATE','UPDATE'):
        data = {
            "workflows_name": args.workflow_name,
            "crond_expression": args.crond_expression,
            "time_zone": args.time_zone,
            "date_format": args.date_format,
            "workflow_status": args.workflow_status,
            "workflow_properties": workflow_props
        }
        if args.operation_type == 'CREATE':
            create_doc(db, data)
        if args.operation_type == 'UPDATE':
            update_doc(db,data)
    if args.operation_type == 'DELETE':
        delete_doc(db)