def parse_concurrency(self, args):
        if not args["--concurrency"]:
            return {}

        settings = {}
        for setting in args["--concurrency"]:
            kv = setting.split("=")
            if len(kv) == 2:
                key = kv[0].strip()
                try:
                    val = int(kv[1].strip())
                except __HOLE__:
                    continue
                settings[key] = val
        return settings
dataset/ETHPy150Open benoitc/gaffer/gaffer/cli/commands/base.py/Command.parse_concurrency