From a61541554d13296e24775c0aa714faf196586536 Mon Sep 17 00:00:00 2001
From: Jeremy Dyer <jdye64@gmail.com>
Date: Fri, 21 Jan 2022 11:18:14 -0500
Subject: [PATCH] remove vim temp file and encode values from python object to
 C++

---
 .../cudf_kafka/cudf_kafka/_lib/.kafka.pxd.swo   | Bin 12288 -> 0 bytes
 python/cudf_kafka/cudf_kafka/_lib/kafka.pyx     |   7 ++++++-
 2 files changed, 6 insertions(+), 1 deletion(-)
 delete mode 100644 python/cudf_kafka/cudf_kafka/_lib/.kafka.pxd.swo

diff --git a/python/cudf_kafka/cudf_kafka/_lib/.kafka.pxd.swo b/python/cudf_kafka/cudf_kafka/_lib/.kafka.pxd.swo
deleted file mode 100644
index 624b60798ae94ece673e4028670bd4d559d7c663..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 12288
zcmeI2%ZnUE9LH<bL}MOG#EU4DvqWds-Pv^`5(YektdLcAH^giXS(m1#re>zI-CdpT
zn%N!j5fsFW2mKEc<0D2q=v7Y&9z2?eiYJd=a`6#JB!2r{-TRnbL=dTh5B;cL{i^C)
zk6-spH>Xa|&e0?FDS~uAAwS%F!+dbh!z0&^6LPjS;C^_2NOJpD%Q7ccg})L=Q(D5^
zxWKEC!^s)m=eF=1?#fBlYqcl6f$R!5IyY9#_KK;V8n)G(jPBOGwbsUt^<AxiR$yxd
zda^xnWdGvf=_jM5K3aK{K5%ex>oPi5E1(t73TOqi0$KsBfL1^&pcVLEDImQO@)~+{
zN7Ac><Tz3~-cHh~<o-jY{Nz#}v;tZIt$<cQE1(t73TOqi0$KsBfL1^&pcVKJDq!L-
z^+)a^q_+!=!~g&3`~Ua%5poS&0q=r7I05QlAJ_|iK0wGP;0pK{ybk8T3!nz7;J5vR
zd<nh)Z-Fyl3hV|y?jz(=a30KqIq=tBLT-WY!294F@W3<R*1d$>1fPS?fDb0XuX_l&
z2rhtEz{_9(%!9|kA#md!LVf|?fXm=*;DS@&MKB5~;P%~wTm_fFD(HhMcpUt+8*K*f
zfakz2@HKS%3S0yiK&az~-~%uK3>*hz-~hM|t*?Qr;1YNboCk~G5V&zCA%B9);3KdE
z&VYm9Tl`4#CU_RifKgBZf8fWO-_sv#wl&8n67yQTP5Z)XQD%#PR|9Uh$EoGY!_$VO
z(sH=y$r>Rg<DMJzngR2zW?Uq(2(5OKnnKu=nXJoOHL{a}scosD<NwHsXZq3#zg&sk
z#M(Hfw-iX<ayyYMPd{bIW!mA=ST!a09n)ViM7teunMfDgQYk!(jjOt;j{2NQ;V&hv
zUtXrR6-Xm06O{aTHOki*_aq%ty`gB>l&B?4IF2PHZ*9?%Y)G?C4jZzxhPZb_h9@0|
z%=?g$D5?~WraBX&{uDZsbUmD`EmN9-==qF~MZM3jBjsw;6&=e~3M6&4xNSiue9RP8
z7rIJY-83cZ8p&iYWJelvH&u3h9=>(*Wzy6_ZnS<fIr6Nm=M+ipv|fIC`Gs>LNqYIE
z3j90E58E>drDowq&~vSGJ#Ki?U&^<WWy*~F3Q;_?WVRUu^!e}u#hGj)s^+J)M!fTc
zu9dKw?lfsYP51OCO4e#z%{G3;D0I8Mq=weKw(XTwtx7E)vahQpv-8wNwj1V7)S#G*
z_h!*Giou1r8djh>*gC2z<#(*?x*jMV(rzZr-y|X{wI@#nX}Qudb(4hMZ4KSJ=H&v%
zbFdgtH*QNbVKBL^j$2KXjAPYuEP60bO9InuKm$b&QtD88Sq{TWk<_GgOuJPG&w1C@
zTbH8sP*XK{Z)IGJ<(pb&p&fgR;hGNL)KWCh;t7xnvnRU-Gi|$RvX$IA`qJ580uR{^
z_p9n0Plp7VZL1S(K9@GEVgt>0Tvz<e!aOhD3XA2H-7gd%@Jz;OCH%m<(Xd3L!PoEr
z=9+e+5tXaN4{MEhZ;dl)+ZPV46#dq_o>!qS;k_ox4IS3QkHYJgsONh$WtQU!U($R(
zF59EsVHr8_c#xUr9uoiX92&;+Ju{0hV~>eNGURE!@nyln;g0YJnU6fu6s=4zGr@4H
zdD;DNf#w<YK(??zvfN~`WG^XrGo;6aH}I`aSJEo0(dnt_sc|}gdUj^^C_T1t^2EZ)
Lqo-yU=Ii8dr$l%Z

diff --git a/python/cudf_kafka/cudf_kafka/_lib/kafka.pyx b/python/cudf_kafka/cudf_kafka/_lib/kafka.pyx
index 24d072c544e..bff60e63fdb 100644
--- a/python/cudf_kafka/cudf_kafka/_lib/kafka.pyx
+++ b/python/cudf_kafka/cudf_kafka/_lib/kafka.pyx
@@ -14,7 +14,12 @@ from cudf_kafka._lib.kafka cimport kafka_consumer
 # To avoid including <python.h> in libcudf_kafka
 # we introduce this wrapper in Cython
 cdef map[string, string] oauth_callback_wrapper(void *ctx):
-    return (<object>(ctx))()
+    resp = (<object>(ctx))()
+    cdef map[string, string] c_resp
+    c_resp[str.encode("token")] = str.encode(resp["token"])
+    c_resp[str.encode("token_expiration_in_epoch")] \
+        = str(resp["token_expiration_in_epoch"]).encode()
+    return c_resp
 
 
 cdef class KafkaDatasource(Datasource):