pdk

Keybase proof

I hereby claim:

• I am pdk on github.
• I am phlatphrog (https://keybase.io/phlatphrog) on keybase.
• I have a public key ASDDmJb3H1XYC7i9yQE_BAEPZe7KkcTCCUIxzhROIWTt-Ao

To claim this, I am signing this object:

pdk

  public boolean isJobReady(DataSource dataSource, DateTime batchDate, Map<String, String> params)
      throws BatchJobFailureException {

    String alphaBatchId = params.get("batchId");

    checkNotNull(alphaBatchId, "batchId is required to check status of a Blorp batch");

    boolean ready = false;

    BlorpAlphaClient client = lookupClient(dataSource);

pdk

func isJobReady(dataSource DataSource, batchDate time.Date, params map[string]string) (bool, error) {

	alphaBatchId, ok := params["batchId"]
	if !ok {
		return false, fmt.Errorf("batchId value required in params")
	}

	client := blorp.LookupClient(dataSource)

	response, err := client.status(alphaBatchId)

pdk

    public boolean isJobReady(DataSource dataSource, DateTime batchDate, Map<String, String> params)
            throws BatchJobFailureException {

        String alphaBatchId = params.get("batchId");
        checkNotNull(alphaBatchId, "batchId is required to check status of a Blorp batch");

        BlorpAlphaClient client = lookupClient(dataSource);

        BatchResponse response;
        try {

pdk

func CopyFile(src, dst string) error {
	r, err := os.Open(src)
	if err != nil {
		return fmt.Errorf("copy %s %s: %v", src, dst, err)
	}
	defer r.Close()

	w, err = os.Create(dst)
	if err != nil {
		return fmt.Errorf("copy %s %s: %v", src, dst, err)

pdk

func CopyFile(src, dst string) error {
	checkErr := func(err error) {
		if err != nil {
			return fmt.Errorf("copy %s %s: %v", src, dst, err)
		}
	}
	
	r, err := os.Open(src)
	checkErr(err)
	defer r.Close()

pdk

// GatherItems collects incoming items. If somehow we get more than n, an error is returned.
func GatherItems(n int) ([]string, error) {
	var items []string
	
	items = append(items, GetItemsFromSourceAlpha()...)
	if len(items) > n {
		return items, fmt.Errorf("more than %d items gathered: %d", n, len(items))
	}

	items = append(items, GetItemsFromSourceBeta()...)

pdk

// GatherItems collects incoming items. If somehow we get more than n, an error is returned.
func GatherItems(n int) ([]string, error) {
	checkLen := func() {
		if len(items) > n {
			return items, fmt.Errorf("more than %d items gathered: %d", n, len(items))
		}
	}
	
	var items []string
	

pdk

func CopyFile(src, dst string) error {
	makro checkErr() {
		if err != nil {
			return fmt.Errorf("copy %s %s: %v", src, dst, err)
		}
	}
	
	r, err := os.Open(src)
	checkErr()
	defer r.Close()

pdk

// GatherItems collects incoming items. If somehow we get more than n, an error is returned.
func GatherItems(n int) ([]string, error) {
	makro checkLen {
		if len(items) > n {
			return items, fmt.Errorf("more than %d items gathered: %d", n, len(items))
		}
	}
	
	var items []string