From c7c68a1abe2cc1876c895fbc3b360051e44865e8 Mon Sep 17 00:00:00 2001
From: "Joshua E. Jodesty" <joshua.jodesty@gmail.com>
Date: Thu, 3 Oct 2019 15:31:31 -0400
Subject: [PATCH] semi-final to pr

---
 README.md                         | 171 +++++++++++++++++++++++-------
 distroduce/README.md              |  65 +++++++++---
 distroduce/dist/distroduce.zip    | Bin 33300 -> 36381 bytes
 distroduce/local_messaging_sim.py |  10 +-
 distroduce/messaging_sim.py       |  10 +-
 distroduce/simulation.py          |  22 ++--
 6 files changed, 218 insertions(+), 60 deletions(-)

diff --git a/README.md b/README.md
index 4f2f8ac..b175de4 100644
--- a/README.md
+++ b/README.md
@@ -1,50 +1,141 @@
 ```
-                    __________   ____
-  ________ __ _____/ ____/   |  / __ \
- / ___/ __` / __  / /   / /| | / / / /
-/ /__/ /_/ / /_/ / /___/ ___ |/ /_/ /
-\___/\__,_/\__,_/\____/_/  |_/_____/
-by BlockScience
-======================================
-       Complex Adaptive Dynamics       
-       o       i        e
-       m       d        s
-       p       e        i
-       u       d        g
-       t                n
-       e
-       r
+   ___   _      __        _  __         __           __
+  / _ \ (_)___ / /_ ____ (_)/ /  __ __ / /_ ___  ___/ /
+ / // // /(_-</ __// __// // _ \/ // // __// -_)/ _  / 
+/____//_//___/\__//_/ _/_//_.__/\_,_/ \__/ \__/ \_,_/  
+  / _ \ ____ ___  ___/ /__ __ ____ ___                 
+ / ___// __// _ \/ _  // // // __// -_)                
+/_/   /_/   \___/\_,_/ \_,_/ \__/ \__/                 
+by Joshua E. Jodesty                                                       
+                                       
 ```
-***cadCAD*** is a Python package that assists in the processes of designing, testing and validating complex systems 
-through simulation, with support for Monte Carlo methods, A/B testing and parameter sweeping. 
+## What?: *Description*
+***Distributed Produce*** (**[distroduce](distroduce)**) is a message simulation and throughput benchmarking framework / 
+[cadCAD](https://cadcad.org) execution mode that leverages [Apache Spark](https://spark.apache.org/) and 
+[Apache Kafka Producer](https://kafka.apache.org/documentation/#producerapi) for optimizing Kafka cluster configurations 
+and debugging real-time data transformations. *distroduce* leverages cadCAD's user-defined event simulation template and 
+framework to simulate messages sent to Kafka clusters. This enables rapid and iterative design, debugging, and message 
+publish benchmarking of Kafka clusters and real-time data processing using Kafka Streams and Spark (Structured) 
+Streaming. 
 
-# Getting Started
-## 1. Installation: 
-Requires [Python 3](https://www.python.org/downloads/) 
+##How?: *A Tail of Two Clusters*
+***Distributed Produce*** is a Spark Application used as a cadCAD Execution Mode that distributes Kafka Producers, 
+message simulation, and message publishing to worker nodes of an EMR cluster. Messages published from these workers are 
+sent to Kafka topics on a Kafka cluster from a Spark bootstrapped EMR cluster.
 
-**Option A: Install Using [pip](https://pypi.org/project/cadCAD/)** 
+##Why?: *Use Case*
+* **IoT Event / Device Simulation:** Competes with *AWS IoT Device Simulator* and *Azure IoT Solution Acceleration: 
+Device Simulation*. Unlike these products, *Distributed Produce* enables a user-defined state updates and agent actions, 
+as well as message publish benchmarking
+* **Development Environment for Real-Time Data Processing / Routing:**
+
+##Get Started:
+
+### 0. Set Up Local Development Environment: see [Kafka Quickstart](https://kafka.apache.org/quickstart)
+**a.** Install `pyspark`
 ```bash
-pip3 install cadCAD
+pip3 install pyspark
+``` 
+**b.** Install & Unzip Kafka, Create Kafka `test` topic, and Start Consumer
+```bash
+sh distroduce/configuration/launch_local_kafka.sh
+```
+**c.** Run Simulation locally
+```bash
+zip -rq distroduce/dist/distroduce.zip distroduce/
+spark-submit --py-files distroduce/dist/distroduce.zip  distroduce/local_messaging_sim.py `hostname | xargs`
 ```
 
-**Option B:** Build From Source
+### 1. Write cadCAD Simulation:
+* **Simulation Description:**
+    To demonstration of *Distributed Produce*, I implemented a simulation of two users interacting over a messaging service.
+* **Resources**
+    * [cadCAD Documentation](https://github.com/BlockScience/cadCAD/tree/master/documentation)
+    * [cadCAD Tutorials](https://github.com/BlockScience/cadCAD/tree/master/tutorials)
+* **Terminology:**
+    * ***[Initial Conditions](https://github.com/BlockScience/cadCAD/tree/master/documentation#state-variables)*** - State Variables and their initial values (Start event of Simulation)
+        ```python
+        initial_conditions = {
+            'state_variable_1': 0,
+            'state_variable_2': 0,
+            'state_variable_3': 1.5,
+            'timestamp': '2019-01-01 00:00:00'
+        }
+        ```
+    * ***[Policy Functions:](https://github.com/BlockScience/cadCAD/tree/master/documentation#Policy-Functions)*** - 
+    computes one or more signals to be passed to State Update Functions
+        ```python
+        def state_update_function_A(_params, substep, sH, s, actions, kafkaConfig):
+              ...
+            return 'state_variable_name', new_value
+        ```
+        
+        Parameters:
+        * **_params** : `dict` - [System parameters](https://github.com/BlockScience/cadCAD/blob/master/documentation/System_Model_Parameter_Sweep.md)
+        * **substep** : `int` - Current [substep](https://github.com/BlockScience/cadCAD/tree/master/documentation#Substep)
+        * **sH** : `list[list[dict]]` - Historical values of all state variables for the simulation. See 
+        [Historical State Access](https://github.com/BlockScience/cadCAD/blob/master/documentation/Historically_State_Access.md) for details
+        * **s** : `dict` - Current state of the system, where the `dict_keys` are the names of the state variables and the 
+        `dict_values` are their current values.
+        * **kafkaConfig:** `kafka.KafkaProducer` - Configuration for `kafka-python` 
+        [Producer](https://kafka-python.readthedocs.io/en/master/apidoc/KafkaProducer.html)
+        
+    * ***[State Update Functions](https://github.com/BlockScience/cadCAD/tree/master/documentation#state-update-functions):*** - 
+    updates state variables change over time
+        ```python
+        def state_update_function_A(_params, substep, sH, s, actions, kafkaConfig):
+              ...
+            return 'state_variable_name', new_value
+        ```
+        Parameters:
+        * **_params** : `dict` - [System parameters](https://github.com/BlockScience/cadCAD/blob/master/documentation/System_Model_Parameter_Sweep.md)
+        * **substep** : `int` - Current [substep](https://github.com/BlockScience/cadCAD/tree/master/documentation#Substep)
+        * **sH** : `list[list[dict]]` - Historical values of all state variables for the simulation. See 
+        [Historical State Access](https://github.com/BlockScience/cadCAD/blob/master/documentation/Historically_State_Access.md) for details
+        * **s** : `dict` - Current state of the system, where the `dict_keys` are the names of the state variables and the 
+        `dict_values` are their current values.
+        * **actions** : `dict` - Aggregation of the signals of all policy functions in the current
+        * **kafkaConfig:** `kafka.KafkaProducer` - Configuration for `kafka-python` 
+        [Producer](https://kafka-python.readthedocs.io/en/master/apidoc/KafkaProducer.html)
+    * ***[Partial State Update Block](https://github.com/BlockScience/cadCAD/tree/master/documentation#State-Variables) (PSUB):*** - 
+    a set of State Update Functions and Policy Functions that update state records
+    ![](https://i.imgur.com/9rlX9TG.png)
+
+**Note:** State Update and Policy Functions now have the additional / undocumented parameter `kafkaConfig`
+
+**a.** **Define Policy Functions:**
+* [Example:](distroduce/action_policies.py) Two users interacting on separate chat clients and entering / exiting chat 
+
+**b.** **Define State Update Functions:**
+* [Example:](distroduce/state_updates.py) Used for logging and maintaining state of user actions defined by policies
+
+**c.** **Define Initial Conditions & Partial State Update Block:**
+* **Initial Conditions:** [Example](distroduce/messaging_sim.py)
+* **Partial State Update Block (PSUB):** [Example](distroduce/simulation.py)
+
+**d.** **Create Simulation Executor:** Used for running a simulation
+* [Local](distroduce/local_messaging_sim.py)
+* [EMR](distroduce/messaging_sim.py)
+
+### 2. [Configure EMR Cluster](distroduce/configuration/cluster.py)
+
+### 3. Launch EMR Cluster:
+**Option A:** Preconfigured Launch
+```bash
+python3 distroduce/emr/launch.py
 ```
-pip3 install -r requirements.txt
-python3 setup.py sdist bdist_wheel
-pip3 install dist/*.whl
+**Option B:** Custom Launch - [Example](distroduce/emr/launch.py)
+```python
+from distroduce.emr.launch import launch_cluster
+from distroduce.configuration.cluster import ec2_attributes, bootstrap_actions, instance_groups, configurations
+region = 'us-east-1'
+cluster_name = 'distibuted_produce'
+launch_cluster(cluster_name, region, ec2_attributes, bootstrap_actions, instance_groups, configurations)
 ```
 
- 
-## 2. Learn the basics
-**Tutorials:** available both as [Jupyter Notebooks](tutorials) and [videos](https://www.youtube.com/watch?v=uJEiYHRWA9g&list=PLmWm8ksQq4YKtdRV-SoinhV6LbQMgX1we) 
-
-Familiarize yourself with some system modelling concepts and cadCAD terminology.
-
-## 3. Documentation:
-* [System Model Configuration](documentation/Simulation_Configuration.md)
-* [System Simulation Execution](documentation/Simulation_Execution.md)
-* [Policy Aggregation](documentation/Policy_Aggregation.md)
-* [System Model Parameter Sweep](documentation/System_Model_Parameter_Sweep.md)
-
-## 4. Connect
-Find other cadCAD users at our [Discourse](https://community.cadcad.org/). We are a small but rapidly growing community.
+### 4. Execute Benchmark(s):
+* **Step 1:** ssh unto master node
+* **Step 2:** Spark Submit
+    ```
+    spark-submit --master yarn --py-files distroduce.zip messaging_sim.py `hostname | xargs`
+    ```
diff --git a/distroduce/README.md b/distroduce/README.md
index 7f15c3c..b175de4 100644
--- a/distroduce/README.md
+++ b/distroduce/README.md
@@ -11,8 +11,9 @@ by Joshua E. Jodesty
 ```
 ## What?: *Description*
 ***Distributed Produce*** (**[distroduce](distroduce)**) is a message simulation and throughput benchmarking framework / 
-cadCAD execution mode that leverages Apache Spark and Kafka Producer for optimizing Kafka cluster configurations and 
-debugging real-time data transformations. *distroduce* leverages cadCAD's user-defined event simulation template and 
+[cadCAD](https://cadcad.org) execution mode that leverages [Apache Spark](https://spark.apache.org/) and 
+[Apache Kafka Producer](https://kafka.apache.org/documentation/#producerapi) for optimizing Kafka cluster configurations 
+and debugging real-time data transformations. *distroduce* leverages cadCAD's user-defined event simulation template and 
 framework to simulate messages sent to Kafka clusters. This enables rapid and iterative design, debugging, and message 
 publish benchmarking of Kafka clusters and real-time data processing using Kafka Streams and Spark (Structured) 
 Streaming. 
@@ -41,24 +42,65 @@ sh distroduce/configuration/launch_local_kafka.sh
 ```
 **c.** Run Simulation locally
 ```bash
-python3 distroduce/local_messaging_sim.py
+zip -rq distroduce/dist/distroduce.zip distroduce/
+spark-submit --py-files distroduce/dist/distroduce.zip  distroduce/local_messaging_sim.py `hostname | xargs`
 ```
 
-### 1. Write cadCAD Simulation: 
-* [Documentation](https://github.com/BlockScience/cadCAD/tree/master/documentation)
-* [Tutorials](https://github.com/BlockScience/cadCAD/tree/master/tutorials)
-
+### 1. Write cadCAD Simulation:
+* **Simulation Description:**
+    To demonstration of *Distributed Produce*, I implemented a simulation of two users interacting over a messaging service.
+* **Resources**
+    * [cadCAD Documentation](https://github.com/BlockScience/cadCAD/tree/master/documentation)
+    * [cadCAD Tutorials](https://github.com/BlockScience/cadCAD/tree/master/tutorials)
 * **Terminology:**
-    * ***Initial Conditions*** - State Variables and their initial values (Start event of Simulation)
+    * ***[Initial Conditions](https://github.com/BlockScience/cadCAD/tree/master/documentation#state-variables)*** - State Variables and their initial values (Start event of Simulation)
+        ```python
+        initial_conditions = {
+            'state_variable_1': 0,
+            'state_variable_2': 0,
+            'state_variable_3': 1.5,
+            'timestamp': '2019-01-01 00:00:00'
+        }
+        ```
     * ***[Policy Functions:](https://github.com/BlockScience/cadCAD/tree/master/documentation#Policy-Functions)*** - 
     computes one or more signals to be passed to State Update Functions
-    * ***[State Update Functions]((https://github.com/BlockScience/cadCAD/tree/master/documentation#state-update-functions)):*** - 
+        ```python
+        def state_update_function_A(_params, substep, sH, s, actions, kafkaConfig):
+              ...
+            return 'state_variable_name', new_value
+        ```
+        
+        Parameters:
+        * **_params** : `dict` - [System parameters](https://github.com/BlockScience/cadCAD/blob/master/documentation/System_Model_Parameter_Sweep.md)
+        * **substep** : `int` - Current [substep](https://github.com/BlockScience/cadCAD/tree/master/documentation#Substep)
+        * **sH** : `list[list[dict]]` - Historical values of all state variables for the simulation. See 
+        [Historical State Access](https://github.com/BlockScience/cadCAD/blob/master/documentation/Historically_State_Access.md) for details
+        * **s** : `dict` - Current state of the system, where the `dict_keys` are the names of the state variables and the 
+        `dict_values` are their current values.
+        * **kafkaConfig:** `kafka.KafkaProducer` - Configuration for `kafka-python` 
+        [Producer](https://kafka-python.readthedocs.io/en/master/apidoc/KafkaProducer.html)
+        
+    * ***[State Update Functions](https://github.com/BlockScience/cadCAD/tree/master/documentation#state-update-functions):*** - 
     updates state variables change over time
+        ```python
+        def state_update_function_A(_params, substep, sH, s, actions, kafkaConfig):
+              ...
+            return 'state_variable_name', new_value
+        ```
+        Parameters:
+        * **_params** : `dict` - [System parameters](https://github.com/BlockScience/cadCAD/blob/master/documentation/System_Model_Parameter_Sweep.md)
+        * **substep** : `int` - Current [substep](https://github.com/BlockScience/cadCAD/tree/master/documentation#Substep)
+        * **sH** : `list[list[dict]]` - Historical values of all state variables for the simulation. See 
+        [Historical State Access](https://github.com/BlockScience/cadCAD/blob/master/documentation/Historically_State_Access.md) for details
+        * **s** : `dict` - Current state of the system, where the `dict_keys` are the names of the state variables and the 
+        `dict_values` are their current values.
+        * **actions** : `dict` - Aggregation of the signals of all policy functions in the current
+        * **kafkaConfig:** `kafka.KafkaProducer` - Configuration for `kafka-python` 
+        [Producer](https://kafka-python.readthedocs.io/en/master/apidoc/KafkaProducer.html)
     * ***[Partial State Update Block](https://github.com/BlockScience/cadCAD/tree/master/documentation#State-Variables) (PSUB):*** - 
     a set of State Update Functions and Policy Functions that update state records
     ![](https://i.imgur.com/9rlX9TG.png)
 
-
 **Note:** State Update and Policy Functions now have the additional / undocumented parameter `kafkaConfig`
 
 **a.** **Define Policy Functions:**
@@ -95,6 +137,5 @@ launch_cluster(cluster_name, region, ec2_attributes, bootstrap_actions, instance
 * **Step 1:** ssh unto master node
 * **Step 2:** Spark Submit
     ```
-    PRIVATE_IP=`hostname -I | xargs`
-    spark-submit --master yarn --py-files distroduce.zip messaging_sim.py $PRIVATE_IP
+    spark-submit --master yarn --py-files distroduce.zip messaging_sim.py `hostname | xargs`
     ```
diff --git a/distroduce/dist/distroduce.zip b/distroduce/dist/distroduce.zip
index f6523407a8ed8493965e11d0d7967f6d1b2f40e4..3a0a0acba316d788b30196f04774d08ce90545f0 100644
GIT binary patch
delta 8144
zcmZu$1zc54)4yE0ySqcWySqU;MY_A=(jcX9C<T;8KqRiTq!Q94ASK-?NGb4Ld>-HD
z@qNE@f9LMZ?#%3-vpZ-0JDVO2&dUX3Xsf{^pn>kMhTv2TIwThLOmhWwK*s?ez`;iW
z_XVfwFe54aQCa)^6b$D2j|@-_&kz1v1)C5BdJSKW0ON~FQ0@zWmVg*&$B4vC^pMj^
z#7#y~2ZKPb0S!!M2%~VOIWz3`4L}FMA$*4efe;8_<EYY8OPuG%Y5!pue@26x^ob~F
zHXPe^PL9<)(=Et^sGz^j@MC5YgZo3-+hC<MOVx8DN_OYXoC~>kc@sp>JDAGfIq9fy
zG!||sBlKQsf^){bF0S_aZBz{k1=S3w9NJ0^Se{=P@H0VT@#*K3BL_|TKP@-n+qVHX
z<*F}-NAuD$U+pXF1RcL7=ylRRPuj|Fa(}<5W2_c4gfoWvP@1Qk$9+Sz;%W0rFS|Tu
zYu8Da7fv?sI%svw)FO?O29Vc_$5AoWL}5dFNB6N=w%;j-MwoicAGLi9Ny1pU=0qM>
zdAWkUtq2K1xV>+D_-Od~1f$i9A0#J!Y?_>(U-{$>YfqzaaukG%tSx!CE+1Vn$~DEX
zI1X<$mUlhk;=mC+7BtKJxZ`sa;@zwtbXl!hRfprn?lIhkchP6f`J{up_crXsUWcil
zRsR*djd#T5=fP*^5@Q$n3r0(%daTL9w$<CIyUo(u5dST&<aYi9O8T6F##|n4KA`~7
z9&X~Xyw4w;5)bRL8<1a=)@|-E$GhnCCEl4b%Z<v*1ZqLXc9qAiw?z-El$7R@sW|4C
zZFGDiWypB=^Li51vGXe99+@T6GoQ$?q9<#LvBZU;_f#K~5-Dl=-kgVAczs!NKa^S(
z7FPc<ZZE^*N)|$BblFl)$AKZ%M2-n*IS&!CbgLn;I)C>OgPhiOg_B9)iXp8abKX#&
z=m^7+NLK*CjQtzY{;q}Qbh>8S`MBQtL&3wY$4ypiO^7@NnB=P4e$r?`P=$G$qoJGO
z0Tbps5YUP(`>*v0kl_f!RxeZ!rwshN8V6tg9})%d#FzNZ!WJ|zh_83g(h_|6r&bjn
z<`aM!Va7jIC;%3b35<n05s}0FySk8A>0TPTPaOH59`EfYl3Cu1?~^@8`YjG~IiQeM
z<Trav`^U(&=ydK|XbDJw7P_|ILieW9>1BR(F-vd$N7uTH#xOBx730`_H59^3k9z;?
z#oQk7_aza3I|^1qu$<PLWsL$`cn~NI9at5ohunVzxM25xd1jA+jx)?N!)B^+zC^h?
z)s-ArfCH5c21t?!8zeGlY)l;$TnB;ms*<ygBZe;twq?$(gm$upr;DK%i+Mh1)nv2+
z2L5OV#jiakl`Wiy7M+=CrxM?BzV1GDM6-YEIGw2nT`I^*eF)ilcUdEu)A%B*La0D@
z;yNMKES;@pK%s5Tu&Ve);+&}vW+nQnPel|*(}XU8>&Pa*&~z~_<EY4~j8WBd2F>TI
z39JgV#ejao7mk@cei=QoOQ3;uxo?eCt}sf)lXK4Gg06GCkY-x;bl|lqYeaYkPEb?_
znf%X1+QL_QUN0aS;ceX)C?D`Q7=_OHO^_m1+vrr_2lsgfhfJLc997tS71&KZNNTBG
z1b%x&#I*K?VK63|Q`s)Zx)VvH7e6$TN`2MY)GB0L0Qn2&V(J6dxmfm)Tj<*-iC=gf
z%qUoyAiSg{ozn3M>_bkAWwWi6QiHB*%7_Fh*t#SKM3(aqUy$&R{u4X9E8#QN^1g6E
z{QU1jkDK<H__c0hHaAn+@U)`N><i1{Ok1Q}xOTQ5S|F1-rA*m2ebS}y3t@Pbv_8q<
zGLOzCP-g4zw#d+#qq{Doe1bNDKZMY8FdZ9kp(7QtY=qGjUL>`b|7{QXJw9*E$M;w^
z^$IA2E^!YAAbZ)1b?-mRmd+{&0o;hh!<cHPh0BX(<l}0Y4R2O3k`KgA-)S3kC+eT6
zyxz-HET7qjFaJ#QdggSlrvd8a8=oNLYR2=)<4xKS0W|L12U+tiNuf^VV48uk43CB<
z(g#%P6&L3NydMW{uLE+0>r}CB0__b;SJQ6k(#jjASRvDI3}n+N?QN|pzRm<360sku
z+EZ=8Yk$aj;FfSj`uWUEmn1xRo1tgxogVwiA>m}&Rzd(tW78SZCMu(l_dMAPYrmG~
zwW`qGH~Klv8*p*sIGSZy(xQ}?a3e$-hRZin{aPA7ZL_fsyO?)cZ))9<zdm<``|+5x
zNfdf}q$Unopk{5id-q7Us*v2TjOM-IR)FD-{?uz~+w}c$wF>o&?w6wi8@BIJsyOK<
zGm$j&9|yieWWMlQsN)DDcR0@@-xB_@V196^R+(eKb)vK^p*BV@f<-1KMA~}<WEJm5
z&FQ@&=VKq*i@8B!4D&OZf7*e%2dANAaVR+(bLkL6M!YR_AD8c=Aqq&*Q%);e$iPem
z7C1`*7ikWpXpu~F0d?S&GzG*y9|I+FkpqdpSTnBB0f+yP00BWm2aWa#fijz~)n&(p
z@~)#jJF?FEABQ(M8kO%9HmjeYRgtAX9ISE>#*5&2U({*G|5ZvHOTE;FR+Z1bBx2gp
zDJIR)Ucoif<FP#S*>W9$7ysqKN8>FUNJTF5q<3}k2D6xU`k}-?OsxrIgK~|P<<QC9
zUwc}c79YW<n?O6sW5~2QbC*qEA^Z7jD<R<}Q!KD`EQK_M*r4|Wk`2KVFfN_r2UHp3
zSc7O`Llol!I)p8((5z+js`11a1ad8c2!yu-3t~>%u_G@xu%>fa^YBZXpW+_%t`_Uw
zJem1~U|YXDfrpmOcZe|qLAtg0iWf~DpOzUCl!J%iHvzVScmH6knX7rBDU@Ye(sx%e
z#fDDHh4{AFaP>A|i18b7@9bBuhc_3eoERdINS6_u4pGvHFwiwzI{Bb!6j}*x**>Mj
zLkU8Z8#nW}<1;3;PF8$pnS4l2rASZvNJ_yi&>)k8F+t-AEa^!-NT&Fbo1Omq%MRZu
z{~<btqb+O`Jpzfimy=WmA`@Z9_S53DaTSCZY4HUc>@PQ(k4zWiR@vTr;8JJQjcvY*
zdA$8p`x^Yp%C%T8i@JKgaquwA`wo#y?nAmhR)VAXT4iVV%rJrDqp7aNp6x#8QUA$}
z-UM7bEpPP>?8iihE}DAjDRih#O`(Q?=bz%4X!S!ozp%S^y**ra(Ab%ErdH<&QH|xu
z{w}mn-bkhR&MFjj5h-5Ao!9xrI#AwWY_zvc{SN^2u>sa)xsgoi|APSUL(66`9-t)0
z{wuur$z8zz3Va?)9ly#4!pu-(W%7HV2lZ2*ybo_sH7yyqUyV<-Cw`T;ToOQmj?+C2
z#nPn*gS~A4K0PKRlRrBO(i4EG1GRd$_f~54e<EPz!9r88HyN2fDhOmo1+<z_L$1~S
z-_Uem?CL$=gnK(;S(`VM%aJTUr}BgL#gY%jd|Pqbnc1M5Xps#|d^BT<N+fc)U%K;M
zus`u~PVsy7J+2v%r|dxI<F6-=YArak;6NWe)xUO1)!q%lFRI<8T6ma86CAAwQ;lDv
z6lRk^dicY+-scOA=pHlX<6elQltJXFJl8wu>}J(Z$I=6O7}(<D0|~~F@7n!GaZaWC
z>G4C#PBs&l3O)nAd#tNddy4*H%A-w_$%OO@exK(}l}u<UAstVH6EI;+<6O68`j;s%
zr(B3?N$tEuh5HZG_6)ZtCy;ZDCD-ViNeoCY@dSftrAz66CpXnoE?#TjhKefn71hdj
znhYu3Cjsx39TSu!Df~x^P67~~!@<SyE52dOe)HN}hC(KtbvD`Hd(gwrL<V*0f-z$k
z#?7%}9B5as&m<IrQsd8l?yr70>75%GDn$8ug3s1Q74ee=cyUFzO>e`(zWz<dDc$Z7
z#M9u34ZW2G?OIAi!Ho7XMeP&CHyUHl?(`QH6MN+st6IxWZd>#ieQDJOi4;cJI%M^}
zpd6+n#f&_t)3Qlhd%j*@t1DMH(CT9DY~esdb5d^hc~4;6iS--n+w^B>4?3N6$ZQOS
zcX4|268j{a^IoN3OeyX<vK`go(Z@`d96-dD1`4~Cc3ck4T=nG`a{@@Y-;vlO?G~X4
zktbEM_pm9^@e14ek&YCmBTt#Va52{utz=RkW02MUTq(|%W3}*kF@?qgx`uV;6=@dV
zE|}-MMYMy~7`cYoC#=WZFwILTv%Hxq84ZH|tPd)tkcuKt-C(%f)ahy_{!!wy6$0@C
zk5sUY;%(`liL``onvpEm4G%TC+LdysK>-^(aMvvp>Ge=+l6r5v_7FFq8i_PvneK6Q
z-g07w;+}(ZZTosD&j68)F8Qod$2_@~1nEl!o7yu*xAD9;8{d;p9+a?~&{v>|TrdLu
zUtJs47fsWBIFsZd-2p!p7dsj4tsw}+-)Pl5tQ$&4#_G2!UNc;6@<7RxhFe9(UeH!e
zSf3AE?&B+FqHePJzm!zNd#=`4X@|3qN*d>3y7{H;%)*0wy6_ZRu~ox^XF<1jf~x$1
zy3!6F7G<*ClV~B9SUmg{olOzOkD6ylsH1K&9JX)Sx^bJ>sd=kZ!<azLrBjfOf~k)D
zsg7M;sYvG-#VltZiol=9j-Kc!$=9RXH>A1I+<jg1XkmI!`d9e8?3(%*+0BaYEbKqE
z(F$5hx4kkg#685veZ0PuewlL4S;-N#mo}1?!JU&oP(l3c%27%U2v;+_Dfw#UAZeSS
z){L6F=2nkMz%@SVx5GPmfGP+f#4qJX>1@e}y*;SmA<K73Pb8C|-dazZC5?HoJw*N#
ze`39bGq@S7p6zbBRJ@>fw?HiYROf;UPsLsIk#kw81>y6Uop*DZN4x`N)iv9rV!q~h
zR`0A4;%er)y^4}Ja9dU^k9D@|t)8}azKT88q{kCdo|?DG^^hPBRubQU;OfH(q4Bgz
z_nB-7b!SGkT7%tbJ`~C865(Ec$0jwi!PR!0C&7@SM1Nu%-#1yof#LvSb;yc+Ggr@F
zF`d0;@to&!lA7~c$u%q2Sw10%kf|cxqM-6{OC|P)nxdP2bT(I!EDk3o_TD(wj~ucH
zM*QZhYNL6(@9|Ylsbtt>kc`Uje$!-;_I;}w&y5+1-fQsnCfqHi*(WJZB1fR%7$t8%
zdoh93g>k9Gw>!x3+%YNk;i}BKfF?z2)%pMehG`aMQG>_Fsfq@_q5;2;d{2OByi2Mu
zQoR>SZ;TdLh+a_*FWY=mNZYbx4vb(ZTcP%ge=REAUD*AlXp6aws|><ib{PQxq>vPo
zZ;*@R-Iz_)6`l4NDSE{k5h!zf(wc~C;PqII-nxM&WxgtE{8`L|&$nu|Av)1S!+^&q
zates;O^=qoMNF1o#vCuJY-pCx=INf~SrWXW>_bsCV$lG3qGr53UJ<y}Y*|a}I?3(w
z=AUnth_(_Y8OK9^;|1YTN6=8hXW6hG3T)W&ZTH~EHY`pp9;n1uvO1|KoUyA>ha!xI
zv$AiR>a~Vfn4b+7m~1%ta_gn8kv=TX?5h$z`KdF&#y&AF&2c1LMifcz=xgDuA?C2c
z{E8-YGi5Sme@2si8qcrGay<*1S~+g!GC?@qCnslDR@~IQYXTyRkVS-oB+*%FBI5^V
zd}h?VUNkWv9#bYZawTZDRJ*3(W;d+sSj!|N2aOXM3z#QWjKehkz?0j#rs(wcm?AWU
ztI_UL24}L4-3z}@Dc0huekmRlxk9E?D1}c9JBOp;&4cITD&|Tm1)9<v2SOVPEc0qs
zQoMH0zts^ZkD5UgBy8hLbQ7EkUTI{PD`zHe?O2qiInanM%+gU~UgSr0eqcGZVNRDT
z+%Zp#g;G%n_MEv%rzNx025eSDNZ%Sh4eXFvbl1MPgZB;lfgvDiT3v7Ee-W->ID1K>
z|8~}?05qt=bXpje=din{%w7r=%n;A^niKC4w4!lMyvBu4SPr{eVulmATTOgEK_1Wj
z&~CcdvY9TY@rv1mNwtiV2hzB$H`@J1nhSc!<$F7tB_tKC-%N!V@Z>h9E=`vIS%|hp
zIh7SXm04!O)FRE8Bkq)~HIG3%$NrU33kg?L>7H~O{%-$1YQ8D)(gCLwTFa}EYl)ry
z5|<&?Y%58K;XLleEtZ+S+8N`Hw4viS?KJD$H>b3Yug&Qd!-le7I!2aOkF)s;<5=p}
zLJ~v}-FN7uRg(Qx+XcKWweuS;2OGDMDEpH(^`c6x>gQyw-N$^yOm5D(N{%T*B$M-2
z*G_JE6GE-WI$tgx#<Vg*EabDM<F3Bf<YpHrltcR=LdijxSTiyDF9PZ{r+hzY?)kH`
zkSs8hD~m3Kl6tN$SwMP}-Fn5bt;Qb#>yqW}yx2t8V)`1)^|s&WqN$sMKihN5wL&V)
zz5+w7g%W#+B`@2ZKkziPZTn~16ohJFAYMskZ(Ss`*0LxNCNJ--Xk%n2MZRTQv+%60
zj)^XS&=;4cP7sAijgYrCK3Yzzag_N{&l^aEK7TgBY|ba@hAw(2LRZo2T(yga9DC=D
zdK^#pup_Q$PMxvv;Ova$_;FKu5$i->ecR)^(Y&HZuP;0ypAaZ!KH;+n?~(;|V24tz
z-8!`N^%+UEx=~GQc&Nhh*+pGC5;j4j?gYkCX~pdwHm7fL$<t&y_!oEdg0M^@Y!AEI
z8828nN*;Vcxxxlm9_#*secA#f(2U2hR3Qw_CD=Xzlm1RL`q;>6-6tG>UyJ~@76q}T
zrAMH(m9>Mdr6rfX9x4d_PaKMSua)=m`i2CSrg(+`0*T#g;s0C9+Qrw~$JPtbCL)0R
zrTjk`4A+O|?(>2K88%;P+j_5@rr$anHoEsddf++njwRMA#o9-4WvXTpOv_F3?y!DH
z9#0@m)%xZsIQW=))^cL+<u~GU{(+Q9Bob7-brEF4ttB<e>gp^^3E``6O7#vTcO+kv
z1lqzT)ovjrLfoAQ=w3l{r{X*`*oa0srY}|0S!7WMjw!{nO>3|+Fl?DzI+<L$&c(6C
z?gpi%e!BGr6V)yU+jY_hyn*c^zB5dAK0T!nkFh@n44e^O%K7@9dodt$#VQ`y)`fO$
z@Rxpft2FHRXe|GnMl5gX(UhZ*60>kYZ8g$D-+C=1sgJhedTFVPmg=B`?1-}cW#?@e
zUm#1{^%8lAZ-9L571<I+7p}zXjmi28VX+dpv}89HLQM00bV)18v{et>O7wL{W*iAJ
zU2LoE$p;jL<mjb#M+i^pzwJMmFVZb&Qeu`GjA~5zAp7ZkIoO9AXC&L3F(W_KCwvD!
zZnh^DlAAU``4Fnxs`Z(_p3h$>aFM2No^;UqRcjV=K#!TrsYkbX;KSjjTw(#|Ou=Ei
z{n(=vl`H&<HPEOX?vjy7!KXY%{-iNm{7v1S0Of|P{QV*${qWfX>?loLG%WHNNkS^7
z9zkNGD#M(5abwF*bK+QpU#3bkH6Pa|HPz#>L(ra)(qJ2C`{9eYZuJhC5eHSR7~4Nf
z&&rszoYhk0EnKZjSs`Ry_Wc;6Dwt=qTTwgq#Lj8p1ALx(2}E+g5$Q<j<`nu>DmQKM
z^Nr2e%@pZEcS}-6gI39VHDQiDBxn4Df;St{w~QD%1Ml??ZE1ml31s$HS?U(-hnQDo
zUm=~&i>vCN^JR}mF)?;#m6Tl>A2VFVJQGLV7C`qALt+VJH*>ja@lRYX6A-J)pQq3%
zK_Kr#vu*L6xyJP+#+tzNGp$d}($_5|ym;BufmxgSWwZe@n)ehh#)p$rIA4!XsVp$!
zZCZ+2!J;Us=ZZ+D)ZR0&qeo)c>1}Rs7p3gXQ)niCp|QzN#xXQ%$na8XNTtxA*~sH1
z-a*8{y8S}q2EO8FP%lgO7knJ1r<<h)jzibj|7-=lZRCJ{YzlH)S1+!AyVx(s{Bz$%
z3zOCQ!2Xo!5SE|Vf;lEHhyrBe=<Va>ZsTih%Vp~dz%~<*zm)#hA@zne7huch?%TtB
zkKF=&Z@J+9*hmw7LWM=Ju8x&Vjebc+ML&5CqbYNWi#=}T0jfno85(LzXv)$LQ1khe
z;qp|ie+13vv_AaNA)$_uAI;6A@Y6@zKe8;}TK(i<8;rccYA}L}gkZYp7V$|Ar<7||
zT6a0>i1~`9I6fj5BUbF|*-X{(zhg@>SY*#zl<%L-$)A42)xD(GZ$z6j+rr%*IMKvg
z%Te_p*v33Z3S(c{emyxUHP9`u(%o>7g5#9`$f><F(Dd{nJ^c2W@(EuS`V5o2tu#Nh
zYPO;nvAmlDp{5vq45FARSjT0q?Qa50w%WRPANOL!s?ioG_cLhfjG%Hp#=GU;HQ2FX
zVJzuW;j$w22dM%%QO5v{S@ezM2l;;JaX3`+NePN|v`~&I?phlTbW&YeQ(LqdlPCQN
zAEuTrm7-1>BX0uPm9cTr8)8Cn9R&hWT<^==Lb^n)!fYa02;P!W8M~sM3qMnfoaCAo
zktm_0^fgZtz>saUpn5|i9jFPAsPxNSa`f*WAV-r9GKcWeSRb+|{dDe0`B({;md3m&
zi?_msZOLU=oU0v)fXcFqR{=(`5Hzq9FkoZDaR${!Za^z+!6h=r>XB6T3U9+-8T9ZB
zrT`XQ%y3)~Y$?N%*U#8-v=bTj5OZ}_-H#|0HJT*IEEP@HNeK0**uJ!xXYrs?N(Y9o
znl8%_X8Ry6^N?bYaOmR2+bI7e{_K-~5QWg)etHejVvsXe1*^9xR3pRb%R3c!x>xQR
zZh+^wxn;6)^JTi5zAi~F%sUFq&+9-b>vNQ-i-vC?ZBdH{=ObZzGU!t-*K&rVvWpxX
zOsZPBGIx^`JLs7ioSYM8>4L=;)t=vZo5-MER4>REg&NJ?S8DN>Yc+e!mpLqydEHvs
zUrrt5kN_`wLxmd$3dW?6y$AfLyuZ`!QN1#_hDwXNWvMh61bt(V)Aba%F)5D>#+Iyq
z*^OREYV$#_X7~2VRsSurwi+Cm3jX(@8$j*A4Q9DNO{0XJwgDavzp@}O4*JodAO63N
z&7QjmfEk7FWq|`1D!3T{!}SpyJK*a22)uv?c)Ak-8?LfoHvC_tG(IMv?j{Y6`in(#
z#{g>FWWkHSSzEZzfQP#!94j#9?gZBf`=<t$2r&RV4{0zB5issf1xOOn16=NO0J<j?
z*pwLX^r8jSJ!Qe~?n!z8>Zt}N40w2P0vuklaCtB)4opA|TzQ#*9cckiAAG>U8zy{D
z5(1xS(SadvX*e{%!-odo@R5bHf>D9shxETBZ+%q3rN2oOz}8m-jL7(R3kpEPhy`%@
zFaZXPSXd;#aRaD0!sg#17{E&}3c%Hc8i??tf|CI9{es{M0Z)H?fYV<VZXZUO!*v6r
z{-$uAz=HrQxN#skzy>~u8w3P%(*Oj4(s17a{Xk<lTA(`64*o_61l$VI17bnaaI!#1
zkRtV;2PGg73G8=&!458AL)ipYf@uDlNMe9H5Q+Maye%RKMEi$$9v~IW3XT@JpG$Zc
zwgE<b$iXslKy4^Fvc4YTJ^X<+5d+J?4B+%%)c|dXD%eZ@UILJo#|Lskq~V?cGNBZJ
zg%V0ys5Dqv`B$5Hs4g4;)Py>K&9(j(Mh3*gw85p?zu59H9dNMDFH%JZ7hr)%gPC=I
zu`v*y``la;go5mu9_Y`HxEBnR!A52B*Qj962cU;j!GF;M0m*vgfKs?LxJw@>@FNA1
z^~r&@a5|blb9W#R!5@#0VG7)ZlY_6-em&&9IgJn;KqUeTJZ|&%ps|6d2nF!5Juna<
z2+;T<05uRKn*YI$e_I8Ca6kt#El&5ke}KY&ze`v*zYP2VBmZOIeiBKY?+vj2JLLV1
zDmkq^0(~6Z-8lG!IAK8bAG4J3_rdbmg`BC>?SJ0czYYD@`{VlGxcTpu{o}ul!J;TL
Z;_n&2Pm4stk_X9y>c~MLeXsjf_<!twJ1GDF

delta 5422
zcmZu#1yogA^S?ni(&eSQTX-NT-3`(pNK1>rg-atyY*Iy0LP>!Of`H@$0jVoWmqkcQ
zBMScuzW4v$7w4>X_RQ>=J+sf+vwpLu;2|t47Di&I1IHnPoIfni86@m@Q>;0*V{E{X
zodyU~;lYZXGmLof#@PNTtj*tr!H87AN9ctPD1%GFE=-uvKj39Juo0@F5`yyqw6W8H
zHWCzRuAZuakQV$v6b6AP0zFb5r2a{^Z8KGlZBQsN1d6i{g+Oqqu`yJc>iN#F(zl&h
z6s|{cun82@t8yIIxXQ2Bcvz!N%-B%1cb#Hzo8D3%w{PM8oZ6EW-j2MwMOT6$<<Fzi
zmxlG1e(2Q;%*?VIw7PZlGl<&1O519xg!gXiuqaQ%fE<r!i}^EiX#ry76aKQ&s0CqE
z$oxTqFiw7djJf{x**?q-B~#6{6k$1GalhFQY?~{Uj>eQY;R8~Bm3v(_EjjrCH{u$I
zP2T$M{Yi0!QI}?iXy^SEqfu!O?j%9Vl4L2Aan`cCYFUEH>W#;&vWU?TTuaN;%PiEB
zc%><VQRT^y_fMH^WBL$YNSuk%!r8=hj(LNj{;X5r(_cB@$(L0`5?I}Y?y?M3P@sxs
z>dQ29D)q*N%72Zjg-;Wi8E%b@O;xuCh5dM;Ul5$WGrd@~mwH=P`I$jioEX{R=h?Gv
ze<J50MB#nnRQrNt*Q>BIg5fHvD)ka+P0>?Sq_~6(!7rbPDon05a(9>i#zP?l$?PEf
zk^YrI(ml7`nyDiBx+Ruqx4d$-AB5sId$r^*ya(SIAiN#;SVujy-g&1#wz_>IfpQ>-
zx7mj)q0W(BJmCpVckF#=;L2AmPkf0%>*w{iQzL}Fe>iPmkod4RHW$#|zA%T}J4ku_
znjYQU8}a8dU5A0<vsoS6oW=NTz1yw3d@)|)Y|kk-)#;AqZPc8!;qSsT>~$vtJ(5fH
z7+cexnCJB!8GY?0wMQ*1YR&9C>5bGf+18<r;Mx*g8hTu(cM1g)<SKuiKOjvZ3u~rA
z`%yfD{T7{{P!*sYMgs(?2tX>8!rz+9RHnaAC_ONv?)+Q2fBO<prxAtsl>!h-ll`}t
zpVk_yjE<*eg8nUPqtk$Q9RV}}J?bx4OyC)#{ka+eQ$F5rwcq*C#&!i70lr640}}SX
zBK7+1`@`R>)o>`E`$X??*#6}K0W_k>Kopn8`HKBqqtNs50S^b^`TjaY{ot@_Dzvy{
z8v$9dzN!IPh=Jo3I0OPC0;hj)Ak}{T@9Z+eW|t_*>op64sZMDR7o8bf*im{VZ?dhq
z!weq*&Xl?Fle!Wu|B1pC<YPszH+5q{bKKOayqRff#cE^Peq~SOcxyl_N=4J!Q}b7C
zE@VaRdakANE|0cv^{si)O0DJ5{*DUb>&QrJ+aV^s{BOE7Sxxg)rhcWc3e<#rvoGg(
z*2L=uiell6i89)k#o9V{(zyAbyR11n8H9LOW74gul3K;%XpD#+q}!SEai*CzzQZxP
z*^Q8TDtT4mQ5~ms9yM)iSr8AS?Dd>JD|c(FAdV8YMNY_k=L=fO$iu`%s7`XgjT)rH
z5l*3%QRnl9HyCjOY6OiIqveu_)za&dB}NI;G6jFH)b7On(MlfQ!7i89Y);(VQsT^}
zCCeJ+d*9U_N4Y&X8Ze`ue>nuL*1@mOZKZU_EMN6}(3B?>)7z85z7yTYD@7vvVzg`1
z+%~yj<{0s+N}(*O>sX7ZXy)BSFbxDb?8AF~gc*^h$hCiIGz?aM{|d?Dx!9$i_R;Hz
zKIEsH8IcBiJApcBX&XW;5kqTgsvBTBHdipt@r}k#k7nEKea}00OG@(^w#E%$O*dMb
z@RQA#6!P;6pSMhN&zrm_MeGX3JH$Jmji;6`T<vDbjpiy2VyzH@6mrU2I$FO$e#xLt
zT@sH|Y%Yi`yM=jQSC7x-y*!<0R~P6?>gK*ayzZfEMJa?{k+29Mz4y*8fTXxidDPCp
z6EQP1uuh#lZ+hhP^rNNvE1?_sb7L&B$4-7v>PWlI?3@x!@*aG|8F6R}3QjuNYB&5Y
zduuW4{oZoS%v7?@Pb#gajHM>ewUAX!YVz8aH!BuCgl@`k`sldj9*P-ui&zK_9Mg;+
zSvyHU(nht2UWl1+PVJor$7Mb))ALUD^{p#-qD|#^Sl<8ZAhz4RuXK#<u|9rS6dHG|
zK*Yg+ePeihh}wstDGa@Na+#bsuS*`K!)``92V%qp>tC<5XuD+?UbW0(#vmEYUuLyg
z2Bh-crF#-gH5DHF>V7gcW}N<H>{hkSk>V(`$>n9~lXvcz6|Pn>NjJh!wvrq$#C4k2
z%2j5R=gVDT(cSd^j9Zu71t42a3NhP)F~r-%=TLbLQUs8j*p%z^L2dJ5@k|yM0%3zN
zLtJhK1p52B1Ub8kfL<jg<cFXCI|ohWu{lUFzb`-#Qb<C88WX~kEcS^fAx-WrNJbTw
z0X<80+)NKr`qM3i%&=aDw{fk9AtL72WQxC#J@ks|!vb7tV5X^^VCbtmKjaAF%(MTP
ze#M*CI_!r9IC(6<nYx)v6B8REHOhLUM(8LC8h@4Q^l|$?%Z|CrBs;yAsC}~l<I2OT
z@y3?r6WK7Mu-Ucrk=SeZvh6~BC;S73g)HSI8b0Zh|LDUwRHj>`Ck!k1Pe0G+tYc5%
zn};|T^Y$f+k;m13kY)>2%%F?24Aq-wroF(o*zy6$`%KhzEWUXtxg$-)9a+C<HaZ9R
zmz<TZc^T6*;C!XmC=l2Xq`&*ZzFk6vX)qJv_;iC39z4M298-^LCXU6o<E7xOy>0sf
zxed{;C7pLx<#+v1!$O2~C6cqgCTAhLd?`}M9*<$k$Uy#_h_s&ya*brxI{e-Qez({c
zUga~YMZRns|DsdXa~nx1F`Ppl?^6mjc*9(Z_X8bf>)o&V^2<hsTa%p1kDC0T@3eMn
zc}0&E#uv36@_Les*I2Laej5ydr+eD_&uK@i7s)!^bK>}MEUEBiv_EE?j3=+r(ruR~
zxZ!CY?+b(J=8exw-_ea<Kdq~0O-Q{~_ln&6HAu`o>q=H>KW_S`VGBKGxk&38qaTkg
zEn?k(c5Ky%7Cq}!S8C!c>HTgof}o)zi`3o}vv9<4G{@3VwX(K0A)($rRarEJFL3+t
zK_x)`t2SG;Q3Vbh%wWWjjM&VS5CT`H{;MKm0*_P`LAM$edP{W~4)?am22&dCaE0Y;
z^aD*5oO85T&>e%FkM#!1&~r^dVAKWo#VQUNJ-e_>Fs6dRl&^z_rrdbn{<ZLDQz;lX
z8(=g$J;xqK^Pf0K7H3t1m2B}58GH!j%_Rtg`ri+}vAVLFp1QEN%SDXmr6duya{SL4
z&(hm>rjPP;*j_AwI#n(23)gBcRTwYx%<JaY_0?SVWPUIY_3Gj{E#a1y`l7<CZ4&74
z?CjYmA@Ll@yDhsrgD0YE`*M&dNxfC7BOdRwoz891Q*H9TT-F}^ypn)V2CQ0IhT8Z?
z9VA5o<0x`y!O?;h<1Yr+Vy%;mnvTu;Y3!NVndPi(AGK84j}Bwb$oLR{hWp2l1kOi{
zO6<up%n&3d$UMCKi()viqql>gPps7~JeFwnXjfGZ36qXHOz{nfYWHmM#kt;dB$PYO
z^2q2{^W(*dcU5AiB6b}oul<l#N}+t-H%vFOs=HW8x^-L&j2`s%Gy9|rKhXWeH`ukU
z_)I|YSeB`6q}z{d02O6yEf9RElK+89x*CNUnU8NEdS)UuCbhCIf^RUUJh(>cX_mqC
zABM#e8A$tw_Nbqn==du-dw6w3_;KM`cwen$U#P##t*JDE-91g1R7@l*jjoa|#AF#q
zaO0jz3ox#2i;sOU-(c+S5Jcm@nw4x}!7%bA6I|i?(naWZ&6Kt$`;lC{pQtP|+fI$W
zwR@$ck#J+VO8dv4uf0Bgb(P;M_N?){3pSs-EGr<1bMn65fFal_4^~{QlJuh0uD$1X
zyG7({^p=A?*L<T~Vx>yX86_;JJm*E^dN{_rvXQ~Qbj4r8J22ijv8^`7GnZ^td*ow`
zcy|$ZKx)P@GYpxwCx(+3fE+W(y0u($shqW^f`^o@YWf8i!Y$Xr&u$`apw$AiyaH?X
zL@y)DM;?Vl9DI4Lc_&NwfCRP7C%<pCCN9pvp(56;TmIaTu>JYsw>j_SSM>8iY+h3o
z^W!U*qBR9<d}2LCX~$UQZ7WFBojRFag?2-Fed~kWQ=fZg{V}dPAJKj_J!H#pEUxC#
zFG9!ADht1!sl1Moa8m|z1K)2j+dEI*T4(w`LT1f4d(DePhnCh)$F65@|CG3vLzvUN
z{YY^{+)C5ljF{jNAE9$o1<^jMjmZ1;h=k#*3>%7_J@v(vMT|E+bTw9~$XHTuB&85j
zt0pCFbKXT=`otRsV%-{9wXIf~ISDO36p1%~+Ip|#!?$md^&>ayhm7hs9={6AiigHM
zj$Gs!E6aG4sCx(Mk$p#_nBe#A>UcyDH_;L5DK71+*gJ@CNE!Y+HJnSIy|%7<(`oG}
z$<!`J(s`nFPRFQ*Y7Ny=2&x6buf<I4cN&LPmNods&fzzdFGP8~n6YWbahXf8I!mlQ
zuJm{u;N}<oHQDZ<W_-oH@t|z=E=sQ_rOXRyqCMuRicdZymR~<rOhMYLDAdPLCPQ?^
z9VgE5nx@YKk1WBC*dE84FN+7wVG`zxuE!M4g2sY#O*hC8C=0PxnMvxFQqh5sdc>wk
z(6}MVk^A-$*>3yPpZUU|@%bmme7-@(`h*hB$$l4OqVkuV2%S7IXci;&RL${B<aRak
z^CSF+1p+r~ZhlkQBFnq^$K<MPYju{Yc(PKp>_*v@Yt(d-hdj~Z;j7!D*#iz_q4zY5
zBtyk^Dfd1To=hy>KQ8=wdd)dOp~GIxztZLVOu=5)+mx{UfV77VPwVf`psP6@pgGfq
zs`F+mlpYyOf-a6_6Q5%m_wSu_KyJmJN+LVoO!+oO+ZcYaF|6MZ$``rzGLUqjvEq#)
z=ail4WV+-gsgiThx(^9qk2~yP#xJr+w<kuA83Xd>1h?k(S&7%x6`AzI?x9y@xqiCu
z_r83|n12(TXod$|RkEn%uVoQE*wX#J8&ZMz)I9B2?o532EI9N2s@lF*Ty`Ytb?6r)
zAB_F*IL%I{uuKk!sn(2r^ihuq7@Au`wP55{!nhkE8F@#j4WBr&*+*PzD(mkF?bQ33
zqUGsi^v<a<fA^aTe84Fc1IxK$SIQsA?O1rADm*|$lC`VP8QVKTd8{R-Fot7mvDsO0
z@6QQVf0B37C-jRfG$cb3UL36-cdR*(6hfy(ZV2fV`FzZf(aMrgTYlgHp6!dx?+U(Z
zvRZ8q-&{T_J5{gUBDp^qFgw32xcHVozEx4kcXG>;-a6~f-RTS&M&-z)_wg?K`jUD*
z`cy@F8K_Q^$fv7&p`ZAonPx=j`{C<BB!_ex)Y+{|4e~p&x8>Yg)NAN=xZ@GGkq7s1
z1xGiLA0oXuc72|^+o<2xIcvZO=#1&_`FuLqncoplvi7s}rqOt&Dn=>J!)IsGQL(8+
z&*8XEsGQx<+xfwVs;YK`o?AGng|zu=_SBkb)27*?*JR09WZaij!Woa|Zn|+s^3oS6
z(HZjM`*%X8CN-T}Qte)oSWDfEi$Eq+6QnKNG->}fklRUp=r!n%XZLMt3*x6JsEkaW
z`J?y8O3p%lfk;zIj{f*|GVI2!5Kn&QipbFI2SZ9b_iZHFZwo%qD`S>9Y&bjPXnOVf
zbTvFE+ioGeecp3z5{i-fNvBANMn6il80iz2Q8TJoV%3c^*k_yOzkjcY{+%>Y*mb(?
z1Z4~Ik4S)VF@|eU=KwD$dbFY|wj(pcik5Isf{{RBm*IbRbbzzJC>)E!pf-RR+sgs<
z{!(ykGv}N|69n|Z|D!WA7c2$U2S!2kpe7Ixh=p8+wgAHr2Pg%o4RL^XT!H`$9Sz_M
zRe_QLOeh1eqap_Bp-NCUEawXC#C|!zLv{urbcY@2g;G#5Lg>#sOW213vZ4Hn`rMug
zU~a2GNdYnp0VKk7pv73q6NW<zqQZFpGFF0Lr8`$;1?hKG;CUCc5P*d%!I>G)<?LXV
zkqF!hSAj?WKhFV9u=7WkAwUel04ySupn4!L!W^0hwjvzin`~G+HfkWxP67fVm7wat
zD3bNUTXit=#b(Kom*FxT5D?A92(*zZ@Z<}c87y!RgO^Ap_$uf595+BjslYY4&grY5
zI+z`3@LVGMdy^1IaWoqbNDE>Br%?{jcwirG1|JoG075|~@Ge>jUMdIy3xW(l7^MU?
z1HLFnXam5YT%dM9I>re)1@dF8;J8u{peV%&7-E&6AAxnOE0h~_#9l-E`!yee{j<N_
zVq0few*!DHjuoc%3$P`!u>JS-<e#c$N)XVj#EFXwfq(c3#8Oybt2SULju|$o0&3%#
z2+T~eGuZkPKqHs|fBa>bfa<v%yj3LvzVS*>LQoU$3*`Z<2`;b&jf*Ly<|TkmP=fL6
zUa%C2y0ATcEXfX{5)GjW0F&qqyJU1RXOm<EYx_;w8Iyy_B=+;l^Jfw>6OSq6pO+|C
zZ-0@CP_Py0MJNWzm!W>ZC)pNeX?F3Cmy#6}{<|Rk=T?iX|82>Cl&9D&PO$=qyYetz
jCv05&;LTlin1(ALOOd9=#XCQ-O4xUU0Ro|PKj;1r&c=!g

diff --git a/distroduce/local_messaging_sim.py b/distroduce/local_messaging_sim.py
index 5c29896..45762c7 100644
--- a/distroduce/local_messaging_sim.py
+++ b/distroduce/local_messaging_sim.py
@@ -1,3 +1,4 @@
+import sys
 from datetime import datetime
 
 from cadCAD import configs
@@ -30,8 +31,15 @@ if __name__ == "__main__":
         }
     )
 
+    # Configuration for Kafka Producer
+    kafkaConfig = {
+        'send_topic': 'test',
+        'producer_config': {
+            'bootstrap_servers': f'{sys.argv[1]}:9092',
+            'acks': 'all'
+        }
+    }
     exec_mode = ExecutionMode()
-    kafkaConfig = {'send_topic': 'test', 'producer_config': {'bootstrap_servers': f'localhost:9092', 'acks': 'all'}}
     dist_proc_ctx = ExecutionContext(context=exec_mode.dist_proc, method=distributed_produce, kafka_config=kafkaConfig)
     run = Executor(exec_context=dist_proc_ctx, configs=configs, spark_context=sc)
 
diff --git a/distroduce/messaging_sim.py b/distroduce/messaging_sim.py
index 3a90dfa..d1b7e15 100644
--- a/distroduce/messaging_sim.py
+++ b/distroduce/messaging_sim.py
@@ -1,3 +1,4 @@
+import sys
 from datetime import datetime
 
 from cadCAD import configs
@@ -30,8 +31,15 @@ if __name__ == "__main__":
         }
     )
 
+    # Configuration for Kafka Producer
+    kafkaConfig = {
+        'send_topic': 'test',
+        'producer_config': {
+            'bootstrap_servers': f'{sys.argv[1]}:9092',
+            'acks': 'all'
+        }
+    }
     exec_mode = ExecutionMode()
-    kafkaConfig = {'send_topic': 'test', 'producer_config': {'bootstrap_servers': f'{sys.argv[1]}:9092', 'acks': 'all'}}
     dist_proc_ctx = ExecutionContext(context=exec_mode.dist_proc, method=distributed_produce, kafka_config=kafkaConfig)
     run = Executor(exec_context=dist_proc_ctx, configs=configs, spark_context=sc)
 
diff --git a/distroduce/simulation.py b/distroduce/simulation.py
index 6bd3695..8dc41eb 100644
--- a/distroduce/simulation.py
+++ b/distroduce/simulation.py
@@ -57,21 +57,31 @@ def main(executor, sim_config, intitial_conditions, sim_composition):
 
     i = 0
     for raw_result, tensor_field in executor.execute():
-        result = arrange_cols(pd.DataFrame(raw_result), False)[
+        result = arrange_cols(pd.DataFrame(raw_result), False)
+        metrics_result = result[
             [
                 'run_id', 'timestep', 'substep',
                 'record_creation', 'total_msg_count', 'total_send_time'
             ]
         ]
+        msgs_result = result[
+            [
+                'run_id', 'timestep', 'substep',
+                'record_creation',
+                'client_a', 'client_b'
+            ]
+        ]
         print()
         if i == 0:
             print(tabulate(tensor_field, headers='keys', tablefmt='psql'))
-        last = result.tail(1)
+        last = metrics_result.tail(1)
         last['msg_per_sec'] = last['total_msg_count'] / last['total_send_time']
-        print("Output: Head")
-        print(tabulate(result.head(5), headers='keys', tablefmt='psql'))
-        print("Output: Tail")
-        print(tabulate(result.tail(5), headers='keys', tablefmt='psql'))
+        print("Messages Output: Head")
+        print(tabulate(msgs_result.head(5), headers='keys', tablefmt='psql'))
+        print("Metrics Output: Head")
+        print(tabulate(metrics_result.head(5), headers='keys', tablefmt='psql'))
+        print("Metrics Output: Tail")
+        print(tabulate(metrics_result.tail(5), headers='keys', tablefmt='psql'))
         print(tabulate(last, headers='keys', tablefmt='psql'))
         print()
         i += 1