etl

Tell us about the problem you're trying to solve

For some cases users have a more restricted access to their ElasticSearch cluster and need private keys.

Describe the solution you’d like

Add an option to upload the key file OR paste the key in a field in the destination configuration.
There are other destination examples using private keys already.

Describe the alternative you’ve

Under the hood, Benthos csv input uses the standard encoding/csv packages's csv.Reader struct.

The current implementation of csv input doesn't allow setting the LazyQuotes field.

We have a use case where we need to set the LazyQuotes field in order to make things work correctly.

I am trying to implement retry logic for Aws Aurora Mysql.

In Linq2db there is retyrpolicy already implemented except there is no way to pass retrypolicy to DataContext.
So I have extended the DataContext as follows.

public class RetryingDataContext : DataContext
{
protected IRetryPolicy _retryPolicy;
public RetryingDataContext(IDataProvider dataProvider, string c

The functions in this file should be factored out to a separate utility lib as they are reused in bitcoin-etl https://github.com/blockchain-etl/ethereum-etl/blob/develop/ethereumetl/misc_utils.py

Repro is with Brim commit 617d8f1.

I've noticed a couple small glitches with Space renames that are shown in the attached video.

Repro.zip

1. If a user goes in to rename the Space and makes no changes, hitting "Ok" brings up an error message. They can only get out by hitting the "X" or the Escape key. Technically the error messa

if they are not class methods then the method would be invoked for every test and a session would be created for each of those tests.

`class PySparkTest(unittest.TestCase):
@classmethod
def suppress_py4j_logging(cls):
logger = logging.getLogger('py4j')
logger.setLevel(logging.WARN)

@classmethod
def create_testing_pyspark_session(cls):
    return Sp

Sending a rest call to delete a job specification throws 404 where as grpc call works fine. Steps to reproduce

curl -X DELETE "http://localhost:9100/v1/project/my-project/namespace/kush/helloworld" -H  "accept: application/json"