Merge pull request #551 from v3io/development

dev -> master

README.md

@@ -1037,3 +1037,4 @@ docker run \
 [Apache 2](LICENSE)
 
 
+

backends/tsdb/writer.go

@@ -23,6 +23,7 @@ package tsdb
 import (
 	"fmt"
 	"sort"
+	"strings"
 	"time"
 
 	"github.com/nuclio/logger"
@@ -192,8 +193,12 @@ func (a *tsdbAppender) Add(frame frames.Frame) error {
 					}
 				} else {
 					err := a.appender.AddFast(metric.ref, tarray[i], values[idx][i])
-					if err != nil {
-						return errors.Wrap(err, "failed to AddFast")
+					if err != nil && strings.Contains(err.Error(), "metric not found") {
+						//retry with Add in case ref was evicted from cache
+						metric.ref, err = a.appender.Add(metric.lset, tarray[i], values[idx][i])
+						if err != nil {
+							return errors.Wrap(err, "failed to AddFast and Add")
+						}
 					}
 				}
 			}

clients/py/v3io_frames/__init__.py

@@ -82,6 +82,9 @@ def Client(address='', data_url='', container='', user='',
     ----------
     A new `Client` object
     """
+    address = address or environ.get('V3IO_FRAMESD')
+    if not address:
+        raise ValueError('empty address')
     if not (address.startswith("grpc://") or address.startswith("https://") or address.startswith("http://")):
         address = "grpc://" + address
     protocol = urlparse(address).scheme or 'grpc'

clients/py/v3io_frames/client.py

@@ -12,8 +12,6 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-from os import environ
-
 import pandas as pd
 
 from . import frames_pb2 as fpb
@@ -183,9 +181,6 @@ def __init__(self, address, session, persist_connection=False,
         ----------
         A new `Client` object
         """
-        address = address or environ.get('V3IO_FRAMESD')
-        if not address:
-            raise ValueError('empty address')
         self.address = self._fix_address(address)
         self.session = session
         self._persist_connection = persist_connection