Commit b4c13939 authored by Ekaterina's avatar Ekaterina

embulk test works

parent 41dc36d5
kldFTgABGGdXm5NOVU1QWQEAtgB7J2Rlc2NyJzogWygnZGF0ZScsICc8TThbbnNdJyksICgnc3RhcnRfZGF0ZScsICc8TThbbnNdJyksICgneCcsICc8ZjgnKSwgKCd5JywgJzxmOCcpLCAoJ3onLCAnPGY4JyldLCAnZm9ydHJhbl9vcmRlcic6IEZhbHNlLCAnc2hhcGUnOiAoMTAwLCksIH0gICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgCkAvH6DJqCUWQC8foMmoJRYYLURU+yEJwBgtRFT7IRnA0iEzf3zZIsCAcS6gyaglFkAvH6DJqCUWQ9RhmACgCMBD1GGYAKAYwDJfSXIAeCLAwLM9oMmoJRZALx+gyaglFm97f9wFHgjAb3t/3AUeGMCTnF9lhBYiwAD2TKDJqCUWQC8foMmoJRaaIp0gC5wHwJoinSALnBfA9Nl1WAi1IcBAOFygyaglFkAvH6DJqCUWxsm6ZBAaB8DGybpkEBoXwFQXjEuMUyHAgHproMmoJRZALx+gyaglFvFw2KgVmAbA8XDYqBWYFsC1VKI+EPIgwMC8eqDJqCUWQC8foMmoJRYdGPbsGhYGwB0Y9uwaFhbAFpK4MZSQIMAA/4mgyaglFkAvH6DJqCUWSL8TMSCUBcBIvxMxIJQVwHbPziQYLyDAQEGZoMmoJRZALx+gyaglFnRmMXUlEgXAdGYxdSUSFcCuGcovOJsfwICDqKDJqCUWQC8foMmoJRafDU+5KpAEwJ8NT7kqkBTAbpT2FUDYHsDAxbegyaglFkAvH6DJqCUWy7Rs/S8OBMDLtGz9Lw4UwDAPI/xHFR7AAAjHoMmoJRZALx+gyaglFvZbikE1jAPA9luKQTWME8DxiU/iT1IdwEBK1qDJqCUWQC8foMmoJRYiA6iFOgoDwCIDqIU6ChPAswR8yFePHMCAjOWgyaglFkAvH6DJqCUWTarFyT+IAsBNqsXJP4gSwHR/qK5fzBvAwM70oMmoJRZALx+gyaglFnhR4w1FBgLAeFHjDUUGEsA0+tSUZwkbwAARBKHJqCUWQC8foMmoJRak+ABSSoQBwKT4AFJKhBHA9nQBe29GGsBAUxOhyaglFkAvH6DJqCUW0J8elk8CAcDQnx6WTwIRwLjvLWF3gxnAgJUiocmoJRZALx+gyaglFvtGPNpUgADA+0Y82lSAEMB4alpHf8AYwMDXMaHJqCUWQC8foMmoJRZN3LM8tPz/v03cszy0/A/AOuWGLYf9F8AAGkGhyaglFkAvH6DJqCUWpCrvxL74/r+kKu/EvvgOwPtfsxOPOhfAQFxQocmoJRZALx+gyaglFvt4Kk3J9P2/+3gqTcn0DcC82t/5lncWwICeX6HJqCUWQC8foMmoJRZSx2XV0/D8v1LHZdXT8AzAflUM4J60FcDA4G6hyaglFkAvH6DJqCUWqRWhXd7s+7+pFaFd3uwLwD/QOMam8RTAACN+ocmoJRZALx+gyaglFgBk3OXo6Pq/AGTc5ejoCsAAS2Wsri4UwEBljaHJqCUWQC8foMmoJRZWshdu8+T5v1ayF27z5AnAwMWRkrZrE8CAp5yhyaglFkAvH6DJqCUWrQBT9v3g+L+tAFP2/eAIwIJAvni+qBLAwOmrocmoJRZALx+gyaglFgRPjn4I3fe/BE+OfgjdB8BDu+pexuURwAAsu6HJqCUWQC8foMmoJRZbnckGE9n2v1udyQYT2QbABDYXRc4iEcBAbsqhyaglFkAvH6DJqCUWsusEjx3V9b+y6wSPHdUFwMawQyvWXxDAgLDZocmoJRZALx+gyaglFgk6QBco0fS/CTpAFyjRBMAOV+AivDkPwMDy6KHJqCUWQC8foMmoJRZgiHufMs3zv2CIe58yzQPAkEw578uzDcAANfihyaglFkAvH6DJqCUWt9a2Jz3J8r+31rYnPckCwBJCkrvbLQzAQHcHosmoJRZALx+gyaglFg4l8q9HxfG/DiXyr0fFAcCVN+uH66cKwIC5FqLJqCUWQC8foMmoJRZkcy04UsHwv2RzLThSwQDAFi1EVPshCcDA+yWiyaglFkAvH6DJqCUWeIPRgLl67794g9GAuXr/v5oinSALnAfAAD41osmoJRZALx+gyaglFiQgSJHOcu2/JCBIkc5y/b8bGPbsGhYGwECARKLJqCUWQC8foMmoJRbUvL6h42rrv9S8vqHjavu/nw1PuSqQBMCAwlOiyaglFkAvH6DJqCUWgFk1svhi6b+AWTWy+GL5vyADqIU6CgPAwARjosmoJRZALx+gyaglFjD2q8INW+e/MParwg1b97+k+ABSSoQBwABHcqLJqCUWQC8foMmoJRbckiLTIlPlv9ySItMiU/W/StyzPLT8/79AiYGiyaglFkAvH6DJqCUWjC+Z4zdL47+ML5njN0vzv1LHZdXT8Py/gMuQosmoJRZALx+gyaglFjjMD/RMQ+G/OMwP9ExD8b9Ushdu8+T5v8ANoKLJqCUWQC8foMmoJRbQ0QwJxHbev9DRDAnEdu6/XJ3JBhPZ9r8AUK+iyaglFkAvH6DJqCUWKAv6Ke5m2r8oC/op7mbqv16Ie58yzfO/QJK+osmoJRZALx+gyaglFohE50oYV9a/iETnShhX5r9mcy04UsHwv4DUzaLJqCUWQC8foMmoJRbgfdRrQkfSv+B91GtCR+K/0Ly+oeNq67/AFt2iyaglFkAvH6DJqCUWgG6DGdluzL+AboMZ2W7cv+CSItMiU+W/AFnsosmoJRZALx+gyaglFjDhXVstT8S/MOFdWy1P1L/I0QwJxHbev0Cb+6LJqCUWQC8foMmoJRbAp3A6A1+4v8CncDoDX8i/0H3Ua0JH0r+A3QqjyaglFkAvH6DJqCUWgBpLfFc/oL+AGkt8Vz+wv8CncDoDX7i/wB8ao8moJRZALx+gyaglFsAaS3xXP6A/wBpLfFc/sD8gqHA6A1+4PwBiKaPJqCUWQC8foMmoJRbgp3A6A1+4P+CncDoDX8g/6H3Ua0JH0j9ApDijyaglFkAvH6DJqCUWQOFdWy1PxD9A4V1bLU/UP+DRDAnEdt4/gOZHo8moJRZALx+gyaglFoBugxnZbsw/gG6DGdlu3D/gkiLTIlPlP8AoV6PJqCUWQC8foMmoJRbofdRrQkfSP+h91GtCR+I/3Ly+oeNq6z8Aa2ajyaglFkAvH6DJqCUWiETnShhX1j+IROdKGFfmP2ZzLThSwfA/QK11o8moJRZALx+gyaglFjAL+inuZto/MAv6Ke5m6j9kiHufMs3zP4DvhKPJqCUWQC8foMmoJRbQ0QwJxHbeP9DRDAnEdu4/XJ3JBhPZ9j/AMZSjyaglFkAvH6DJqCUWPMwP9ExD4T88zA/0TEPxP1qyF27z5Pk/AHSjo8moJRZALx+gyaglFowvmeM3S+M/jC+Z4zdL8z9Sx2XV0/D8P0C2sqPJqCUWQC8foMmoJRbgkiLTIlPlP+CSItMiU/U/UNyzPLT8/z+A+MGjyaglFkAvH6DJqCUWMParwg1b5z8w9qvCDVv3P6T4AFJKhAFAwDrRo8moJRZALx+gyaglFoRZNbL4Yuk/hFk1svhi+T8jA6iFOgoDQAB94KPJqCUWQC8foMmoJRbUvL6h42rrP9S8vqHjavs/nw1PuSqQBEBAv++jyaglFkAvH6DJqCUWKCBIkc5y7T8oIEiRznL9Px4Y9uwaFgZAgAH/o8moJRZALx+gyaglFniD0YC5eu8/eIPRgLl6/z+aIp0gC5wHQMBDDqTJqCUWQC8foMmoJRZocy04UsHwP2hzLThSwQBAHC1EVPshCUAAhh2kyaglFkAvH6DJqCUWECXyr0fF8T8QJfKvR8UBQJg364frpwpAQMgspMmoJRZALx+gyaglFrjWtic9yfI/uNa2Jz3JAkAUQpK72y0MQIAKPKTJqCUWQC8foMmoJRZgiHufMs3zP2CIe58yzQNAkEw578uzDUDATEukyaglFkAvH6DJqCUWDDpAFyjR9D8MOkAXKNEEQBJX4CK8OQ9AAI9apMmoJRZALx+gyaglFrTrBI8d1fU/tOsEjx3VBUDHsEMr1l8QQEDRaaTJqCUWQC8foMmoJRZcnckGE9n2P1ydyQYT2QZABTYXRc4iEUCAE3mkyaglFkAvH6DJqCUWBE+Ofgjd9z8ET45+CN0HQEO76l7G5RFAwFWIpMmoJRZALx+gyaglFrAAU/b94Pg/sABT9v3gCECEQL54vqgSQACYl6TJqCUWQC8foMmoJRZYshdu8+T5P1iyF27z5AlAwsWRkrZrE0BA2qakyaglFkAvH6DJqCUWAGTc5ejo+j8AZNzl6OgKQABLZayuLhRAgBy2pMmoJRZALx+gyaglFqgVoV3e7Ps/qBWhXd7sC0A+0DjGpvEUQMBexaTJqCUWQC8foMmoJRZUx2XV0/D8P1THZdXT8AxAf1UM4J60FUAAodSkyaglFkAvH6DJqCUW/HgqTcn0/T/8eCpNyfQNQL3a3/mWdxZAQOPjpMmoJRZALx+gyaglFqQq78S++P4/pCrvxL74DkD7X7MTjzoXQIAl86TJqCUWQC8foMmoJRZQ3LM8tPz/P1Dcszy0/A9APOWGLYf9F0DAZwKlyaglFkAvH6DJqCUW/EY82lSAAED8RjzaVIAQQHpqWkd/wBhAAKoRpcmoJRZALx+gyaglFtCfHpZPAgFA0J8elk8CEUC47y1hd4MZQEDsIKXJqCUWQC8foMmoJRak+ABSSoQBQKT4AFJKhBFA9nQBe29GGkCALjClyaglFkAvH6DJqCUWelHjDUUGAkB6UeMNRQYSQDf61JRnCRtAwHA/pcmoJRZALx+gyaglFk6qxck/iAJATqrFyT+IEkB1f6iuX8wbQACzTqXJqCUWQC8foMmoJRYiA6iFOgoDQCIDqIU6ChNAswR8yFePHEBA9V2lyaglFkAvH6DJqCUW9luKQTWMA0D2W4pBNYwTQPGJT+JPUh1AgDdtpcmoJRZALx+gyaglFsy0bP0vDgRAzLRs/S8OFEAyDyP8RxUeQMB5fKXJqCUWQC8foMmoJRagDU+5KpAEQKANT7kqkBRAcJT2FUDYHkAAvIulyaglFkAvH6DJqCUWdGYxdSUSBUB0ZjF1JRIVQK4Zyi84mx9AQP6apcmoJRZALx+gyaglFki/EzEglAVASL8TMSCUFUB2z84kGC8gQIBAqqXJqCUWQC8foMmoJRYeGPbsGhYGQB4Y9uwaFhZAFpK4MZSQIEDAgrmlyaglFkAvH6DJqCUW8nDYqBWYBkDycNioFZgWQLZUoj4Q8iBAAMXIpcmoJRZALx+gyaglFsbJumQQGgdAxsm6ZBAaF0BUF4xLjFMhQEAH2KXJqCUWQC8foMmoJRacIp0gC5wHQJwinSALnBdA9dl1WAi1IUCASeelyaglFkAvH6DJqCUWcHt/3AUeCEBwe3/cBR4YQJScX2WEFiJAwIv2pcmoJRZALx+gyaglFkTUYZgAoAhARNRhmACgGEAzX0lyAHgiQADOBabJqCUWQC8foMmoJRYYLURU+yEJQBgtRFT7IRlA0iEzf3zZIkA=
kldFTgABGGdXm5NOVU1QWQEAtgB7J2Rlc2NyJzogWygnZGF0ZScsICc8TThbbnNdJyksICgnc3RhcnRfZGF0ZScsICc8TThbbnNdJyksICgneCcsICc8ZjgnKSwgKCd5JywgJzxmOCcpLCAoJ3onLCAnPGY4JyldLCAnZm9ydHJhbl9vcmRlcic6IEZhbHNlLCAnc2hhcGUnOiAoMTAwLCksIH0gICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgCkAvH6DJqCUWQC8foMmoJRYYLURU+yEJwBgtRFT7IRnA0iEzf3zZIsCAcS6gyaglFkAvH6DJqCUWQ9RhmACgCMBD1GGYAKAYwDJfSXIAeCLAwLM9oMmoJRZALx+gyaglFm97f9wFHgjAb3t/3AUeGMCTnF9lhBYiwAD2TKDJqCUWQC8foMmoJRaaIp0gC5wHwJoinSALnBfA9Nl1WAi1IcBAOFygyaglFkAvH6DJqCUWxsm6ZBAaB8DGybpkEBoXwFQXjEuMUyHAgHproMmoJRZALx+gyaglFvFw2KgVmAbA8XDYqBWYFsC1VKI+EPIgwMC8eqDJqCUWQC8foMmoJRYdGPbsGhYGwB0Y9uwaFhbAFpK4MZSQIMAA/4mgyaglFkAvH6DJqCUWSL8TMSCUBcBIvxMxIJQVwHbPziQYLyDAQEGZoMmoJRZALx+gyaglFnRmMXUlEgXAdGYxdSUSFcCuGcovOJsfwICDqKDJqCUWQC8foMmoJRafDU+5KpAEwJ8NT7kqkBTAbpT2FUDYHsDAxbegyaglFkAvH6DJqCUWy7Rs/S8OBMDLtGz9Lw4UwDAPI/xHFR7AAAjHoMmoJRZALx+gyaglFvZbikE1jAPA9luKQTWME8DxiU/iT1IdwEBK1qDJqCUWQC8foMmoJRYiA6iFOgoDwCIDqIU6ChPAswR8yFePHMCAjOWgyaglFkAvH6DJqCUWTarFyT+IAsBNqsXJP4gSwHR/qK5fzBvAwM70oMmoJRZALx+gyaglFnhR4w1FBgLAeFHjDUUGEsA0+tSUZwkbwAARBKHJqCUWQC8foMmoJRak+ABSSoQBwKT4AFJKhBHA9nQBe29GGsBAUxOhyaglFkAvH6DJqCUW0J8elk8CAcDQnx6WTwIRwLjvLWF3gxnAgJUiocmoJRZALx+gyaglFvtGPNpUgADA+0Y82lSAEMB4alpHf8AYwMDXMaHJqCUWQC8foMmoJRZN3LM8tPz/v03cszy0/A/AOuWGLYf9F8AAGkGhyaglFkAvH6DJqCUWpCrvxL74/r+kKu/EvvgOwPtfsxOPOhfAQFxQocmoJRZALx+gyaglFvt4Kk3J9P2/+3gqTcn0DcC82t/5lncWwICeX6HJqCUWQC8foMmoJRZSx2XV0/D8v1LHZdXT8AzAflUM4J60FcDA4G6hyaglFkAvH6DJqCUWqRWhXd7s+7+pFaFd3uwLwD/QOMam8RTAACN+ocmoJRZALx+gyaglFgBk3OXo6Pq/AGTc5ejoCsAAS2Wsri4UwEBljaHJqCUWQC8foMmoJRZWshdu8+T5v1ayF27z5AnAwMWRkrZrE8CAp5yhyaglFkAvH6DJqCUWrQBT9v3g+L+tAFP2/eAIwIJAvni+qBLAwOmrocmoJRZALx+gyaglFgRPjn4I3fe/BE+OfgjdB8BDu+pexuURwAAsu6HJqCUWQC8foMmoJRZbnckGE9n2v1udyQYT2QbABDYXRc4iEcBAbsqhyaglFkAvH6DJqCUWsusEjx3V9b+y6wSPHdUFwMawQyvWXxDAgLDZocmoJRZALx+gyaglFgk6QBco0fS/CTpAFyjRBMAOV+AivDkPwMDy6KHJqCUWQC8foMmoJRZgiHufMs3zv2CIe58yzQPAkEw578uzDcAANfihyaglFkAvH6DJqCUWt9a2Jz3J8r+31rYnPckCwBJCkrvbLQzAQHcHosmoJRZALx+gyaglFg4l8q9HxfG/DiXyr0fFAcCVN+uH66cKwIC5FqLJqCUWQC8foMmoJRZkcy04UsHwv2RzLThSwQDAFi1EVPshCcDA+yWiyaglFkAvH6DJqCUWeIPRgLl67794g9GAuXr/v5oinSALnAfAAD41osmoJRZALx+gyaglFiQgSJHOcu2/JCBIkc5y/b8bGPbsGhYGwECARKLJqCUWQC8foMmoJRbUvL6h42rrv9S8vqHjavu/nw1PuSqQBMCAwlOiyaglFkAvH6DJqCUWgFk1svhi6b+AWTWy+GL5vyADqIU6CgPAwARjosmoJRZALx+gyaglFjD2q8INW+e/MParwg1b97+k+ABSSoQBwABHcqLJqCUWQC8foMmoJRbckiLTIlPlv9ySItMiU/W/StyzPLT8/79AiYGiyaglFkAvH6DJqCUWjC+Z4zdL47+ML5njN0vzv1LHZdXT8Py/gMuQosmoJRZALx+gyaglFjjMD/RMQ+G/OMwP9ExD8b9Ushdu8+T5v8ANoKLJqCUWQC8foMmoJRbQ0QwJxHbev9DRDAnEdu6/XJ3JBhPZ9r8AUK+iyaglFkAvH6DJqCUWKAv6Ke5m2r8oC/op7mbqv16Ie58yzfO/QJK+osmoJRZALx+gyaglFohE50oYV9a/iETnShhX5r9mcy04UsHwv4DUzaLJqCUWQC8foMmoJRbgfdRrQkfSv+B91GtCR+K/0Ly+oeNq67/AFt2iyaglFkAvH6DJqCUWgG6DGdluzL+AboMZ2W7cv+CSItMiU+W/AFnsosmoJRZALx+gyaglFjDhXVstT8S/MOFdWy1P1L/I0QwJxHbev0Cb+6LJqCUWQC8foMmoJRbAp3A6A1+4v8CncDoDX8i/0H3Ua0JH0r+A3QqjyaglFkAvH6DJqCUWgBpLfFc/oL+AGkt8Vz+wv8CncDoDX7i/wB8ao8moJRZALx+gyaglFsAaS3xXP6A/wBpLfFc/sD8gqHA6A1+4PwBiKaPJqCUWQC8foMmoJRbgp3A6A1+4P+CncDoDX8g/6H3Ua0JH0j9ApDijyaglFkAvH6DJqCUWQOFdWy1PxD9A4V1bLU/UP+DRDAnEdt4/gOZHo8moJRZALx+gyaglFoBugxnZbsw/gG6DGdlu3D/gkiLTIlPlP8AoV6PJqCUWQC8foMmoJRbofdRrQkfSP+h91GtCR+I/3Ly+oeNq6z8Aa2ajyaglFkAvH6DJqCUWiETnShhX1j+IROdKGFfmP2ZzLThSwfA/QK11o8moJRZALx+gyaglFjAL+inuZto/MAv6Ke5m6j9kiHufMs3zP4DvhKPJqCUWQC8foMmoJRbQ0QwJxHbeP9DRDAnEdu4/XJ3JBhPZ9j/AMZSjyaglFkAvH6DJqCUWPMwP9ExD4T88zA/0TEPxP1qyF27z5Pk/AHSjo8moJRZALx+gyaglFowvmeM3S+M/jC+Z4zdL8z9Sx2XV0/D8P0C2sqPJqCUWQC8foMmoJRbgkiLTIlPlP+CSItMiU/U/UNyzPLT8/z+A+MGjyaglFkAvH6DJqCUWMParwg1b5z8w9qvCDVv3P6T4AFJKhAFAwDrRo8moJRZALx+gyaglFoRZNbL4Yuk/hFk1svhi+T8jA6iFOgoDQAB94KPJqCUWQC8foMmoJRbUvL6h42rrP9S8vqHjavs/nw1PuSqQBEBAv++jyaglFkAvH6DJqCUWKCBIkc5y7T8oIEiRznL9Px4Y9uwaFgZAgAH/o8moJRZALx+gyaglFniD0YC5eu8/eIPRgLl6/z+aIp0gC5wHQMBDDqTJqCUWQC8foMmoJRZocy04UsHwP2hzLThSwQBAHC1EVPshCUAAhh2kyaglFkAvH6DJqCUWECXyr0fF8T8QJfKvR8UBQJg364frpwpAQMgspMmoJRZALx+gyaglFrjWtic9yfI/uNa2Jz3JAkAUQpK72y0MQIAKPKTJqCUWQC8foMmoJRZgiHufMs3zP2CIe58yzQNAkEw578uzDUDATEukyaglFkAvH6DJqCUWDDpAFyjR9D8MOkAXKNEEQBJX4CK8OQ9AAI9apMmoJRZALx+gyaglFrTrBI8d1fU/tOsEjx3VBUDHsEMr1l8QQEDRaaTJqCUWQC8foMmoJRZcnckGE9n2P1ydyQYT2QZABTYXRc4iEUCAE3mkyaglFkAvH6DJqCUWBE+Ofgjd9z8ET45+CN0HQEO76l7G5RFAwFWIpMmoJRZALx+gyaglFrAAU/b94Pg/sABT9v3gCECEQL54vqgSQACYl6TJqCUWQC8foMmoJRZYshdu8+T5P1iyF27z5AlAwsWRkrZrE0BA2qakyaglFkAvH6DJqCUWAGTc5ejo+j8AZNzl6OgKQABLZayuLhRAgBy2pMmoJRZALx+gyaglFqgVoV3e7Ps/qBWhXd7sC0A+0DjGpvEUQMBexaTJqCUWQC8foMmoJRZUx2XV0/D8P1THZdXT8AxAf1UM4J60FUAAodSkyaglFkAvH6DJqCUW/HgqTcn0/T/8eCpNyfQNQL3a3/mWdxZAQOPjpMmoJRZALx+gyaglFqQq78S++P4/pCrvxL74DkD7X7MTjzoXQIAl86TJqCUWQC8foMmoJRZQ3LM8tPz/P1Dcszy0/A9APOWGLYf9F0DAZwKlyaglFkAvH6DJqCUW/EY82lSAAED8RjzaVIAQQHpqWkd/wBhAAKoRpcmoJRZALx+gyaglFtCfHpZPAgFA0J8elk8CEUC47y1hd4MZQEDsIKXJqCUWQC8foMmoJRak+ABSSoQBQKT4AFJKhBFA9nQBe29GGkCALjClyaglFkAvH6DJqCUWelHjDUUGAkB6UeMNRQYSQDf61JRnCRtAwHA/pcmoJRZALx+gyaglFk6qxck/iAJATqrFyT+IEkB1f6iuX8wbQACzTqXJqCUWQC8foMmoJRYiA6iFOgoDQCIDqIU6ChNAswR8yFePHEBA9V2lyaglFkAvH6DJqCUW9luKQTWMA0D2W4pBNYwTQPGJT+JPUh1AgDdtpcmoJRZALx+gyaglFsy0bP0vDgRAzLRs/S8OFEAyDyP8RxUeQMB5fKXJqCUWQC8foMmoJRagDU+5KpAEQKANT7kqkBRAcJT2FUDYHkAAvIulyaglFkAvH6DJqCUWdGYxdSUSBUB0ZjF1JRIVQK4Zyi84mx9AQP6apcmoJRZALx+gyaglFki/EzEglAVASL8TMSCUFUB2z84kGC8gQIBAqqXJqCUWQC8foMmoJRYeGPbsGhYGQB4Y9uwaFhZAFpK4MZSQIEDAgrmlyaglFkAvH6DJqCUW8nDYqBWYBkDycNioFZgWQLZUoj4Q8iBAAMXIpcmoJRZALx+gyaglFsbJumQQGgdAxsm6ZBAaF0BUF4xLjFMhQEAH2KXJqCUWQC8foMmoJRacIp0gC5wHQJwinSALnBdA9dl1WAi1IUCASeelyaglFkAvH6DJqCUWcHt/3AUeCEBwe3/cBR4YQJScX2WEFiJAwIv2pcmoJRZALx+gyaglFkTUYZgAoAhARNRhmACgGEAzX0lyAHgiQADOBabJqCUWQC8foMmoJRYYLURU+yEJQBgtRFT7IRlA0iEzf3zZIkA=
import os
import subprocess
import unittest
import binascii
import struct
import logging
from logging.handlers import RotatingFileHandler
class TransferDataTest(unittest.TestCase):
from slapos.testing.testcase import makeModuleSetUpAndTestCaseClass
setUpModule, SlapOSInstanceTestCase = makeModuleSetUpAndTestCaseClass(
os.path.abspath(
os.path.join(os.path.dirname(__file__), '..', 'software.cfg')))
class TransferDataTest(SlapOSInstanceTestCase):
def create_embulk_config(self, config, data_in_path, data_out_path):
config_string = "exec:\n max_threads: 1\n min_output_tasks: 1\n" + \
"in:\n type: filename\n path_prefix: %s\n parser:\n type: none-bin\n" + \
"out:\n type: file\n path_prefix: %s\n file_ext: wen\n formatter:\n type: single_value"
config_string = config_string % (data_in_path, data_out_path)
f = open(config,'w')
print >> f,config_string
f.close()
......@@ -20,10 +28,10 @@ class TransferDataTest(unittest.TestCase):
config = pwd[:len(pwd)-4] + "templates/config.yml"
data_in_path = pwd[:len(pwd)-4] + "data_in/"
data_out_path = pwd[:len(pwd)-4] + "data_out/data_out"
self.create_embulk_config(config, data_in_path, data_out_path)
subprocess.call(['/srv/slapgrid/slappart18/srv/runner/software/f5aec1c37c220000ab1c2ef799aac847/parts/java/bin/java',
'-jar', '/srv/slapgrid/slappart18/srv/runner/software/f5aec1c37c220000ab1c2ef799aac847/parts/embulk/embulk.jar',
'run', config, '-b', '/srv/slapgrid/slappart18/srv/runner/software/f5aec1c37c220000ab1c2ef799aac847/parts/embulkPlugins/plugins'])
subprocess.call(['{{ java_location }}/bin/java', '-jar', '{{ embulk_location }}/embulk.jar',
'run', config, '-b', '{{ embulkPlugins_location }}/plugins'])
data_in_file = data_in_path + "data-in.wen"
data_in_file = open(data_in_file, 'rb')
......@@ -34,19 +42,6 @@ class TransferDataTest(unittest.TestCase):
data_out_file = open(data_out_file, 'rb')
data_out = data_out_file.read()
data_out_file.close()
#MAGIC_HEADER = b'\x92WEN\x00\x01'
#crc = struct.pack('<I', binascii.crc32(data_in) & 0xffffffff)
#data_in = b''.join([MAGIC_HEADER, crc, data_in])
data_in = struct.unpack('<I', data_in)
print("DATA: ", data_in)
self.assertEqual(data_in, data_out)
if __name__ == "__main__":
suite = unittest.TestLoader().loadTestsFromTestCase(TransferDataTest)
unittest.TextTestRunner(verbosity=3).run(suite)
#t = TransferDataTest()
#t.test_transfer_data()
self.assertEqual(data_in, base64.b64decode(data_out))
\ No newline at end of file
import os
import subprocess
import logging
from logging.handlers import RotatingFileHandler
import unittest
import base64
from slapos.testing.testcase import makeModuleSetUpAndTestCaseClass
setUpModule, SlapOSInstanceTestCase = makeModuleSetUpAndTestCaseClass(
os.path.abspath(
os.path.join(os.path.dirname(__file__), '..', 'software.cfg')))
class TransferDataTest(SlapOSInstanceTestCase):
class TransferDataTest(unittest.TestCase):
def create_embulk_config(self, config, data_in_path, data_out_path):
config_string = f''' exec:
max_threads: 1
min_output_tasks: 1
in:
type: filename
path_prefix: {}
parser:
type: none-bin
out:
type: file
path_prefix: {}
file_ext: wen'''.format(data_in_path, data_out_path)
config_string = "exec:\n max_threads: 1\n min_output_tasks: 1\n" + \
"in:\n type: filename\n path_prefix: %s\n parser:\n type: none-bin\n" + \
"out:\n type: file\n path_prefix: %s\n file_ext: wen\n formatter:\n type: single_value"
config_string = config_string % (data_in_path, data_out_path)
f = open(config,'w')
print >> f,config_string
f.close()
return config
def test_transfer_data(self):
pwd = os.getcwd()
config = pwd[:len(pwd)-4] + "templates/config.yml"
data_in_path = pwd[:len(pwd)-4] + "data_in/"
data_out_path = pwd[:len(pwd)-4] + "data_out/data_out"
config_path = self.create_embulk_config(config, data_in_path, data_out_path)
subprocess.call(['{{ java_location }}/bin/java', '-jar', '{{ embulk_location }}/embulk.jar',
'run', 'config', '-b', '{{ embulkPlugins_location }}/plugins'])
# data_in = "It works"
# data_in_file = data_in_path + "data-in.wen"
# data_in_file = open(data_in_file, 'wb')
# data_in_file.write(data_in)
# data_in_file.close()
self.create_embulk_config(config, data_in_path, data_out_path)
subprocess.call(['/srv/slapgrid/slappart18/srv/runner/software/f5aec1c37c220000ab1c2ef799aac847/parts/java/bin/java',
'-jar', '/srv/slapgrid/slappart18/srv/runner/software/f5aec1c37c220000ab1c2ef799aac847/parts/embulk/embulk.jar',
'run', config, '-b', '/srv/slapgrid/slappart18/srv/runner/software/f5aec1c37c220000ab1c2ef799aac847/parts/embulkPlugins/plugins'])
data_in_file = data_in_path + "data-in.wen"
data_in_file = open(data_in_file, 'rb')
data_in = data_in_file.read()
data_in_file.close()
data_out_file = data_out_path + ".wen"
data_out_file = data_out_path + "000.00.wen"
data_out_file = open(data_out_file, 'rb')
data_out = data_out_file.read()
data_out_file.close()
self.assertEqual(data_in, data_out)
\ No newline at end of file
self.assertEqual(data_in, base64.b64decode(data_out))
if __name__ == "__main__":
suite = unittest.TestLoader().loadTestsFromTestCase(TransferDataTest)
unittest.TextTestRunner(verbosity=3).run(suite)
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment